Can you post your broker config?
I have been trying 10MB payloads and they work fine. In IRC i mentioned I
was getting OOM, but my test case was trying to send 100MB payloads, not
10MB.
Also,
is your exception stack trace from the client side? Or broker side?
On Wed, Nov 28, 2012 at 10:02 AM, mrloud <jerry.smith...@gmail.com> wrote:
> Extracted from IRC chat with cposta:
>
> I'm getting "IOException: Could not post command" using the http transport
> on AMQ 5.7. Any tips on what I should be looking at to fix this? This is
> going to be a low volume, but possibly large message size, server.
>
> I'm sending in a TextMessage with text set to a string created from an
> empty
> byte array, just so I can experiment with sizes.
> 10mb fails, 5mb completes ususally, just ran a 6mb and it completed, 7mb
> failed with same error
> We are going to be pretty low volume, maybe 500-600 messages a day, but the
> payloads can be larger
> heap size is 1024mb
>
> Client Trace:
>
> javax.jms.JMSException: Could not post command: ActiveMQTextMessage
> {commandId = 5, responseRequired = false, messageId =
> ID:tsg3038-50643-1354119150216-1:1:1:1:1, originalDestination = null,
> originalTransactionId = null, producerId =
> ID:tsg3038-50643-1354119150216-1:1:1:1, destination = queue://FOO.BAR,
> transactionId = null, expiration = 0, timestamp = 1354119150836, arrival =
> 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
> null, persistent = true, type = null, priority = 4, groupID = null,
> groupSequence = 0, targetConsumerId = null, compressed = false, userID =
> null, content = null, marshalledProperties = null, dataStructure = null,
> redeliveryCounter = 0, size = 0, properties = {dealerAccount=123456,
> QuoteTypeID=2, PONumber=0, RequestFrom=FromSendToWorkflow,
> QuoteID=7312264},
> readOnlyProperties = true, readOnlyBody = true, droppable = false, text =
> ...
> at
>
> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
> at
>
> org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1245)
> at
>
> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1237)
> at
> org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1738)
> at
>
> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:231)
> at
>
> org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessageProducerSupport.java:241)
> at mqtest.MQTest.publish(MQTest.java:167)
> at mqtest.HttpLoadTest$TestThread.run(HttpLoadTest.java:101)
> Caused by: java.io.IOException: Could not post command: ActiveMQTextMessage
> {commandId = 5, responseRequired = false, messageId =
> ID:tsg3038-50643-1354119150216-1:1:1:1:1, originalDestination = null,
> originalTransactionId = null, producerId =
> ID:tsg3038-50643-1354119150216-1:1:1:1, destination = queue://FOO.BAR,
> transactionId = null, expiration = 0, timestamp = 1354119150836, arrival =
> 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
> null, persistent = true, type = null, priority = 4, groupID = null,
> groupSequence = 0, targetConsumerId = null, compressed = false, userID =
> null, content = null, marshalledProperties = null, dataStructure = null,
> redeliveryCounter = 0, size = 0, properties = {dealerAccount=123456,
> QuoteTypeID=2, PONumber=0, RequestFrom=FromSendToWorkflow,
> QuoteID=7312264},
> readOnlyProperties = true, readOnlyBody = true, droppable = false, text =
> ...
> at
>
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)
> at
>
> org.apache.activemq.transport.http.HttpClientTransport.oneway(HttpClientTransport.java:101)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
> at
>
> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> at
>
> org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1243)
> ... 6 more
> Caused by: java.io.IOException: Could not post command: ActiveMQTextMessage
> {commandId = 5, responseRequired = false, messageId =
> ID:tsg3038-50643-1354119150216-1:1:1:1:1, originalDestination = null,
> originalTransactionId = null, producerId =
> ID:tsg3038-50643-1354119150216-1:1:1:1, destination = queue://FOO.BAR,
> transactionId = null, expiration = 0, timestamp = 1354119150836, arrival =
> 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo =
> null, persistent = true, type = null, priority = 4, groupID = null,
> groupSequence = 0, targetConsumerId = null, compressed = false, userID =
> null, content = null, marshalledProperties = null, dataStructure = null,
> redeliveryCounter = 0, size = 0, properties = {dealerAccount=123456,
> QuoteTypeID=2, PONumber=0, RequestFrom=FromSendToWorkflow,
> QuoteID=7312264},
> readOnlyProperties = true, readOnlyBody = true, droppable = false, text =
> ...
> at
>
> org.apache.activemq.transport.http.HttpClientTransport.oneway(HttpClientTransport.java:91)
> ... 9 more
>
> Server Trace:
>
> 2012-11-28 10:12:45,266 | ERROR | / | org.mortbay.log | btpool1-3
> com.thoughtworks.xstream.converters.ConversionException: : error reading
> input, returned 0 : : error reading input, returned 0
> ---- Debugging information ----
> message : : error reading input, returned 0
> cause-exception : com.thoughtworks.xstream.io.StreamException
> cause-message : : error reading input, returned 0
> class : org.apache.activemq.command.ActiveMQTextMessage
> required-type : java.lang.String
> path : /org.apache.activemq.command.ActiveMQTextMessage/text
> line number : 54
> -------------------------------
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.convert(TreeUnmarshaller.java:89)
> at
>
> com.thoughtworks.xstream.core.AbstractReferenceUnmarshaller.convert(AbstractReferenceUnmarshaller.java:63)
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.convertAnother(TreeUnmarshaller.java:76)
> at
>
> com.thoughtworks.xstream.converters.reflection.AbstractReflectionConverter.unmarshallField(AbstractReflectionConverter.java:246)
> at
>
> com.thoughtworks.xstream.converters.reflection.AbstractReflectionConverter.doUnmarshal(AbstractReflectionConverter.java:218)
> at
>
> com.thoughtworks.xstream.converters.reflection.AbstractReflectionConverter.unmarshal(AbstractReflectionConverter.java:162)
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.convert(TreeUnmarshaller.java:82)
> at
>
> com.thoughtworks.xstream.core.AbstractReferenceUnmarshaller.convert(AbstractReferenceUnmarshaller.java:63)
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.convertAnother(TreeUnmarshaller.java:76)
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.convertAnother(TreeUnmarshaller.java:60)
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.start(TreeUnmarshaller.java:137)
> at
>
> com.thoughtworks.xstream.core.AbstractTreeMarshallingStrategy.unmarshal(AbstractTreeMarshallingStrategy.java:33)
> at com.thoughtworks.xstream.XStream.unmarshal(XStream.java:923)
> at com.thoughtworks.xstream.XStream.unmarshal(XStream.java:909)
> at com.thoughtworks.xstream.XStream.fromXML(XStream.java:853)
> at
>
> org.apache.activemq.transport.xstream.XStreamWireFormat.unmarshalText(XStreamWireFormat.java:55)
> at
>
> org.apache.activemq.transport.http.HttpTunnelServlet.doPost(HttpTunnelServlet.java:102)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:713)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:806)
> at
> org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:487)
> at
> org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:362)
> at
> org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:181)
> at
> org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:726)
> at
> org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
> at org.mortbay.jetty.Server.handle(Server.java:324)
> at
> org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:505)
> at
>
> org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:842)
> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:648)
> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:205)
> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:380)
> at
>
> org.mortbay.jetty.bio.SocketConnector$Connection.run(SocketConnector.java:228)
> at
>
> org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:450)
> Caused by: com.thoughtworks.xstream.io.StreamException: : error reading
> input, returned 0
> at
> com.thoughtworks.xstream.io.xml.XppReader.pullNextEvent(XppReader.java:80)
> at
>
> com.thoughtworks.xstream.io.xml.AbstractPullReader.readRealEvent(AbstractPullReader.java:137)
> at
>
> com.thoughtworks.xstream.io.xml.AbstractPullReader.readEvent(AbstractPullReader.java:124)
> at
>
> com.thoughtworks.xstream.io.xml.AbstractPullReader.getValue(AbstractPullReader.java:167)
> at
> com.thoughtworks.xstream.io.ReaderWrapper.getValue(ReaderWrapper.java:48)
> at
>
> com.thoughtworks.xstream.converters.SingleValueConverterWrapper.unmarshal(SingleValueConverterWrapper.java:49)
> at
>
> com.thoughtworks.xstream.core.TreeUnmarshaller.convert(TreeUnmarshaller.java:82)
> ... 31 more
> Caused by: java.io.IOException: error reading input, returned 0
> at org.xmlpull.mxp1.MXParser.fillBuf(MXParser.java:2991)
> at org.xmlpull.mxp1.MXParser.more(MXParser.java:2996)
> at org.xmlpull.mxp1.MXParser.parseEntityRef(MXParser.java:2151)
> at org.xmlpull.mxp1.MXParser.nextImpl(MXParser.java:1274)
> at org.xmlpull.mxp1.MXParser.next(MXParser.java:1092)
> at
> com.thoughtworks.xstream.io.xml.XppReader.pullNextEvent(XppReader.java:63)
> ... 37 more
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Large-message-failure-over-http-transport-tp4659891.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
