On Tue, 2010-02-16 at 05:13 -0800, muadd wrote: > Hi, > in order to reproduce this, it should be enough to follow these steps (I'm > assuming 5.2.0 windows binaries): > 1) Add <transportConnector name="http" uri="http://172.18.131.66:61223" /> > to your activemq.xml config file in transportConnectors (change the uri to > match your ip address) > 2) run consumer and producer ant build provided as examples with the > distribution, with the following parameters: > consumer -Durl=http://172.18.131.66:61223 -DsleepTime=1000 > producer -Durl=http://172.18.131.66:61223 -DsleepTime=1000 > -DmessageSize=100000 > (again, with appropriate url parameter) > 3) the moment amq tries to deliver first message to the consumer (i.e. > render the response to the HTTP GET request), the exception occurs > > The reason for the problem - so it seems - is the use of java > DataOutputStream.writeUTF - the implementation being limited to 64k buffer. > The workaround I'd suggest is to use the OutputStreamWriter instead: > OutputStreamWriter out = new OutputStreamWriter(stream, "UTF-8"); > out.write(message); > > best regards >
This issue should be fixed in the 5.4 SNAPSHOT builds, I'd recommend you give that a try. The same issue was reported previously, see: https://issues.apache.org/activemq/browse/AMQ-1308 Regards > > Dejan Bosanac wrote: > > > > Hi, > > > > thanks for raising the issue. Is there a chance you can provide a > > reproducible test case? > > > > Cheers > > -- > > Dejan Bosanac - http://twitter.com/dejanb > > > > Open Source Integration - http://fusesource.com/ > > ActiveMQ in Action - http://www.manning.com/snyder/ > > Blog - http://www.nighttale.net > > > > > > On Tue, Feb 16, 2010 at 10:05 AM, muadd <kszyn...@gmail.com> wrote: > > > >> > >> Hi, > >> > >> I've encountered similar problem with http transport. When I try to get a > >> message with 100KB+ payload (tried TextMessage and MapMessage), I get: > >> > >> 2010-02-16 09:37:28,147 | WARN | / | org.mortbay.log | btpool0-1 - / > >> java.io.UTFDataFormatException: encoded string too long: 219486 bytes > >> at java.io.DataOutputStream.writeUTF(DataOutputStream.java:347) > >> at java.io.DataOutputStream.writeUTF(DataOutputStream.java:306) > >> at > >> > >> org.apache.activemq.transport.util.TextWireFormat.marshal(TextWireFormat.java:44) > >> at > >> > >> org.apache.activemq.transport.http.HttpTunnelServlet.doGet(HttpTunnelServlet.java:86) > > [cut] > > > > > > > > ----- > > Dejan Bosanac > > > > Open Source Integration - http://fusesource.com/ > > ActiveMQ in Action - http://www.manning.com/snyder/ > > Blog - http://www.nighttale.net > > > -- Tim Bish Open Source Integration: http://fusesource.com ActiveMQ in Action: http://www.manning.com/snyder/ Follow me on Twitter: http://twitter.com/tabish121 My Blog: http://timbish.blogspot.com/