activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: ActiveMQ Stomp producer messages size limitation
Date Tue, 13 Jan 2015 14:37:58 GMT
One option would be to download the 5.10.0 code, change the value of that
constant, build and deploy.  But you'll have to test to make sure that
limit wasn't protecting the broker from some problem that happens with
messages larger than 100MB.

Another would be to split the message in half and have your consumer only
ack both messages when the last one is received.  You have to make sure the
same consumer gets all the messages that comprise the original;
JMSCorrelationID might be useful here.

You could put the actual content somewhere both producer and consumer can
access and just pass a reference in the message.  This might or might not
work for your use case, but if it does it'll allow you to reduce the memory
the broker needs, which is a good thing.

You could reduce the amount of data you're sending.  What single message is
140MB in size, anyway?
On Jan 13, 2015 7:08 AM, "khandelwalanuj" <khandelwal.anuj90@gmail.com>
wrote:

> Hi,
>
> I am not able to send message more than 100MB to ActiveMQ broker. Producer
> throws below exception:
>
> /[20150113 03:16:59:609 stomp_client.py:80 ERROR] Received an error:
> org.apache.activemq.transport.stomp.ProtocolException: The maximum data
> length was exceeded
>         at
>
> org.apache.activemq.transport.stomp.StompWireFormat.unmarshal(StompWireFormat.java:128)
>         at
>
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
>         at java.lang.Thread.run(Thread.java:745)/
>
> I checked the source code
> (
> http://activemq.apache.org/maven/apidocs/src-html/org/apache/activemq/transport/stomp/StompWireFormat.html
> )
> and found that "private static final int MAX_DATA_LENGTH = 1024 * 1024 *
> 100;" is causing the issue. How can I change it ? what should I do to send
> 140 size messages ?
>
> Thanks,
> Anuj
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-Stomp-producer-messages-size-limitation-tp4689847.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message