MRG-M message size limit of a String in a MapMessage
Issue
- When trying to process large messages it appears that we are hitting some sort of limit.
- The message just seems to be left on the queue and not read. Smaller messages however continue to be processed.
ERROR [org.apache.qpid.client.BasicMessageConsumer] (Dispatcher-0-Conn-1) Caught exception (dump follows) - ignoring...: java.lang.IllegalArgumentException: unknown code: 105
at org.apache.qpid.transport.codec.AbstractDecoder.getType(AbstractDecoder.java:354) [qpid-common-0.18.jar:]
at org.apache.qpid.transport.codec.AbstractDecoder.readList(AbstractDecoder.java:315) [qpid-common-0.18.jar:]
at org.apache.qpid.transport.codec.BBDecoder.readList(BBDecoder.java:34) [qpid-common-0.18.jar:]
at org.apache.qpid.transport.codec.AbstractDecoder.read(AbstractDecoder.java:457) [qpid-common-0.18.jar:]
at org.apache.qpid.transport.codec.AbstractDecoder.readMap(AbstractDecoder.java:288) [qpid-common-0.18.jar:]
at org.apache.qpid.transport.codec.BBDecoder.readMap(BBDecoder.java:34) [qpid-common-0.18.jar:]
at org.apache.qpid.client.message.AMQPEncodedMapMessage.populateMapFromData(AMQPEncodedMapMessage.java:96) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.JMSMapMessage.<init>(JMSMapMessage.java:66) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.AMQPEncodedMapMessage.<init>(AMQPEncodedMapMessage.java:51) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.AMQPEncodedMapMessageFactory.createMessage(AMQPEncodedMapMessageFactory.java:36) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.AbstractJMSMessageFactory.create010MessageWithBody(AbstractJMSMessageFactory.java:137) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.AbstractJMSMessageFactory.createMessage(AbstractJMSMessageFactory.java:170) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.MessageFactoryRegistry.createMessage(MessageFactoryRegistry.java:155) [qpid-client-0.18.jar:]
at org.apache.qpid.client.BasicMessageConsumer_0_10.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_10.java:209) [qpid-client-0.18.jar:]
at org.apache.qpid.client.BasicMessageConsumer_0_10.createJMSMessageFromUnprocessedMessage(BasicMessageConsumer_0_10.java:54) [qpid-client-0.18.jar:]
at org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:719) [qpid-client-0.18.jar:]
at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:186) [qpid-client-0.18.jar:]
at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:54) [qpid-client-0.18.jar:]
at org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3479) [qpid-client-0.18.jar:]
at org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3418) [qpid-client-0.18.jar:]
at org.apache.qpid.client.AMQSession$Dispatcher.access$1000(AMQSession.java:3205) [qpid-client-0.18.jar:]
at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3198) [qpid-client-0.18.jar:]
at org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54) [qpid-client-0.18.jar:]
at org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3341) [qpid-client-0.18.jar:]
at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_37]
Environment
- Red Hat Enterprise MRG Messaging (MRG-M) 2.2
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.