activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bill Wei (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (ARTEMIS-1268) stomp client can send large message but not receive
Date Fri, 07 Jul 2017 18:35:00 GMT

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

Bill Wei edited comment on ARTEMIS-1268 at 7/7/17 6:34 PM:
-----------------------------------------------------------

[~martyntaylor] This is the ruby file you can use to reproduce:
{quote}
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
{quote}


was (Author: bzwei):
[~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)

Mime
View raw message