So the error is indicating that the client cannot decode the incoming message - in particular it seems to believe the data is malformed. It is trying to decode the message data (section)... it seems to be interpreting the data as saying the described type has a String which is encoded as having length 73450, but there is only 67291 bytes left to decode.
Are you consuming over SSL or is the connection unencrypted - if the latter we might be able to use tools to independently examine the data. Hope this helps, Rob On 3 June 2015 at 12:56, Erik Aschenbrenner <[email protected]> wrote: > Dear Qpid users, > > I'm using the Qpid Java JMS client 0.32 to connect to an AMQP broker. > > My applications uses 3 broadcast topic listeners listening to different > topics. When my application starts it receives a lot of data from the AMQP > broker. Since some time I notice the following AMQP exception on startup. > > Since I changed nothing in the code I assume, that the problem lies in the > received data. > > Do you have an idea what this exception is about? > > Regards, > Erik > > 2015-06-03 12:36:07.998 - ERROR - System.err: > org.apache.qpid.amqp_1_0.type.AmqpErrorException > 2015-06-03 12:36:07.998 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.codec.ValueHandler.readConstructor(ValueHandler.java:133) > 2015-06-03 12:36:07.999 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.codec.ValueHandler.parse(ValueHandler.java:90) > 2015-06-03 12:36:07.999 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.messaging.SectionDecoderImpl.parseAll(SectionDecoderImpl.java:49) > 2015-06-03 12:36:07.999 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.client.Receiver.receive(Receiver.java:334) > 2015-06-03 12:36:07.999 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.receive0(MessageConsumerImpl.java:314) > 2015-06-03 12:36:08.000 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.jms.impl.SessionImpl$Dispatcher.run(SessionImpl.java:928) > 2015-06-03 12:36:08.000 - ERROR - System.err: at > java.lang.Thread.run(Thread.java:744) > 2015-06-03 12:36:08.023 - ERROR - System.err: Exception in thread "Thread-5" > 2015-06-03 12:36:08.027 - ERROR - System.err: > java.lang.IllegalArgumentException: position: 226size: 154492 capacity: > 70027 > 2015-06-03 12:36:08.027 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.codec.StringTypeConstructor.construct(StringTypeConstructor.java:71) > 2015-06-03 12:36:08.027 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.codec.VariableWidthTypeConstructor.construct(VariableWidthTypeConstructor.java:38) > 2015-06-03 12:36:08.027 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructor$1.construct(DescribedTypeConstructor.java:35) > 2015-06-03 12:36:08.027 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.codec.ValueHandler.parse(ValueHandler.java:91) > 2015-06-03 12:36:08.028 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.messaging.SectionDecoderImpl.parseAll(SectionDecoderImpl.java:49) > 2015-06-03 12:36:08.028 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.client.Receiver.receive(Receiver.java:334) > 2015-06-03 12:36:08.028 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.receive0(MessageConsumerImpl.java:314) > 2015-06-03 12:36:08.028 - ERROR - System.err: at > org.apache.qpid.amqp_1_0.jms.impl.SessionImpl$Dispatcher.run(SessionImpl.java:928) > 2015-06-03 12:36:08.028 - ERROR - System.err: at > java.lang.Thread.run(Thread.java:744) > 2015-06-03 12:37:22.967 - ERROR - Caught throwable: > StackTrace************************************************************* > java.lang.Exception - java.lang.IllegalArgumentException in job > StopProtocolJob: icEurexRepo > Caused by: > java.lang.IllegalArgumentException - position: 227size: 73540 capacity: > 67291 > at > org.apache.qpid.amqp_1_0.codec.StringTypeConstructor.construct(StringTypeConstructor.java:71) > at > org.apache.qpid.amqp_1_0.codec.VariableWidthTypeConstructor.construct(VariableWidthTypeConstructor.java:38) > at > org.apache.qpid.amqp_1_0.codec.DescribedTypeConstructor$1.construct(DescribedTypeConstructor.java:35) > at > org.apache.qpid.amqp_1_0.codec.ValueHandler.parse(ValueHandler.java:91) > at > org.apache.qpid.amqp_1_0.messaging.SectionDecoderImpl.parseAll(SectionDecoderImpl.java:49) > at org.apache.qpid.amqp_1_0.client.Receiver.receive(Receiver.java:334) > at org.apache.qpid.amqp_1_0.client.Receiver.close(Receiver.java:549) > at > org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.closeUnderlyingReceiver(MessageConsumerImpl.java:382) > at > org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.close(MessageConsumerImpl.java:371) > at > org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.close(SessionImpl.java:310) > at > org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl.close(ConnectionImpl.java:463) > > > > > > -- > View this message in context: > http://qpid.2158936.n2.nabble.com/AmqpErrorException-when-receiving-broadcast-data-tp7625647.html > Sent from the Apache Qpid users mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
