[ 
https://issues.apache.org/jira/browse/ARTEMIS-1268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16078500#comment-16078500
 ] 

Bill Wei commented on ARTEMIS-1268:
-----------------------------------

[~martyntaylor] This is the ruby file you can use to reproduce:

require 'stomp'

hosts = [{:login => "admin", :passcode => "admin", :host => "127.0.0.1", :port 
=> 61613}]
headers = { :host => "127.0.0.1", :"accept-version" => "1.2", :"heart-beat" => 
"2000,0"}
client = Stomp::Client.open(:hosts => hosts, :connect_headers => headers)

client.subscribe('queue/test', :ack => 'client') do |msg|
  puts "received message #{msg.body.size} bytes"
  client.ack(msg)
end

pub_client = Stomp::Client.open(:hosts => hosts)
pub_client.publish('queue/test', 't'*200000)
puts "message sent"
pub_client.close

loop do
  sleep(1)
end

> stomp client can send large message but not receive
> ---------------------------------------------------
>
>                 Key: ARTEMIS-1268
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-1268
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>          Components: STOMP
>    Affects Versions: 2.1.0
>            Reporter: Bill Wei
>            Assignee: Justin Bertram
>
> I am using a ruby stomp client for pub/subscribe. A message size over 100K 
> can be sent and appears in the data/large-messages folder, but the subscriber 
> never receives the message. However if a smaller message (below threshold) 
> follows the larger one, the smaller message gets consumed, and the larger one 
> disappears from the data/large-messages folder. JMX also shows now all 
> messages are delivered. The stomp consumer never receives the large message, 
> and does not ack it (it was set up to use client ack).
> I also followed the document to configure in broker.xml the 
> stompMinLargeMessageSize, but no matter what the size I tried (2048000 or 
> 2048) it had no impact. The cutoff size is still the default 100K. Here is my 
> sample setting
> <acceptor 
> name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true;stompMinLargeMessageSize=2048000</acceptor>



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to