Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-1696

AMQP message containing UnsignedInteger value cannot be converted to Core

XMLWordPrintable

    • Hide 
      21045 + node bin/sender-client.js --log-lib=TRANSPORT_FRM --log-msgs interop --count 1 --msg-content-list-item  --msg-content-list-item String --msg-content-list-item ~1 --msg-content-list-item ~1.0 --msg-content-list-item 1 --msg-content-list-item 1.0 --msg-content-list-item ~-1 --msg-content-list-item ~-1.3 --msg-content-list-item -1 --msg-content-list-item ~1 --msg-correlation-id corr-id-4 --address JAMQMsgPatterns0beTestsb2EL9Rf
21045 ! 2018-06-21T15:10:54.293Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":["647e0eb3-0cbf-6d49-8da2-94652e92fa1f",null,null,null,null,null,null,null,null,[]]}'
21045 ! 2018-06-21T15:10:54.300Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[null,0,2048,4294967295]}'
21045 ! 2018-06-21T15:10:54.302Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":["6a215a3e-2f6d-6c49-a65a-b8579ec17bab",0,false,null,null,[],["JAMQMsgPatterns0beTestsb2EL9Rf",0],null,null,0]}'
21045 ! 2018-06-21T15:10:55.192Z rhea:frames [connection-1] RECV: { protocol_id: 0, major: 1, minor: 0, revision: 0 }
21045 ! 2018-06-21T15:10:55.198Z rhea:frames [connection-1] RECV: '{"size":188,"type":0,"channel":0,"performative":{"type":"open#10","container_id":"amq","max_frame_size":131072,"channel_max":65535,"idle_time_out":30000,"offered_capabilities":["sole-connection-for-container","DELAYED_DELIVERY","SHARED-SUBS","ANONYMOUS-RELAY"],"properties":{"product":"apache-activemq-artemis","version":"2.6.1.amq-720003-redhat-1"}}}'
21045 ! 2018-06-21T15:10:55.212Z rhea:frames [connection-1] RECV: '{"size":34,"type":0,"channel":0,"performative":{"type":"begin#11","next_outgoing_id":1,"incoming_window":2147483647,"outgoing_window":2147483647,"handle_max":65535}}'
21045 ! 2018-06-21T15:10:55.213Z rhea:frames [connection-1] RECV: '{"size":100,"type":0,"channel":0,"performative":{"type":"attach#12","name":"6a215a3e-2f6d-6c49-a65a-b8579ec17bab","role":true,"snd_settle_mode":2,"source":[],"target":["JAMQMsgPatterns0beTestsb2EL9Rf"]}}'
21045 ! 2018-06-21T15:10:55.214Z rhea:frames [connection-1] RECV: '{"size":34,"type":0,"channel":0,"performative":{"type":"flow#13","incoming_window":2147483647,"next_outgoing_id":1,"outgoing_window":2147483647,"link_credit":1000}}'
21045   {"durable":False,"priority":None,"ttl":None,"first-acquirer":None,"delivery-count":0,"id":None,"user-id":None,"address":"JAMQMsgPatterns0beTestsb2EL9Rf","subject":None,"reply-to":None,"correlation-id":"corr-id-4","content-type":"string","content-encoding":None,"absolute-expiry-time":None,"creation-time":None,"group-id":None,"group-sequence":None,"reply-to-group-id":None,"properties":None,"content":["","String",1,1,"1","1.0",-1,-1.3,"-1",1]}
21045 ! 2018-06-21T15:10:55.252Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[0,0,{"type":"Buffer","data":[48]},0,false,false],"payload":{"type":"Buffer","data":[0,83,112,208,0,0,0,9,0,0,0,5,66,64,64,64,67,0,83,114,209,0,0,0,4,0,0,0,0,0,83,115,208,0,0,0,65,0,0,0,13,64,64,161,30,74,65,77,81,77,115,103,80,97,116,116,101,114,110,115,48,98,101,84,101,115,116,115,98,50,69,76,57,82,102,64,64,161,9,99,111,114,114,45,105,100,45,52,163,6,115,116,114,105,110,103,64,64,64,64,64,64,0,83,116,209,0,0,0,4,0,0,0,0,0,83,119,208,0,0,0,43,0,0,0,10,161,0,161,6,83,116,114,105,110,103,82,1,82,1,161,1,49,161,3,49,46,48,84,255,130,191,244,204,204,204,204,204,205,161,2,45,49,82,1]}}'
21045 ! 2018-06-21T15:10:55.355Z rhea:frames [connection-1] RECV: '{"size":22,"type":0,"channel":0,"performative":{"type":"disposition#15","role":true,"settled":true,"state":[]}}'
21045 ! 2018-06-21T15:10:55.356Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[0,false]}'
21045 ! 2018-06-21T15:10:55.356Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[]}'
21045 ! 2018-06-21T15:10:55.382Z rhea:frames [connection-1] RECV: '{"size":15,"type":0,"channel":0,"performative":{"type":"detach#16"}}'
21045 ! 2018-06-21T15:10:55.383Z rhea:frames [connection-1] RECV: '{"size":12,"type":0,"channel":0,"performative":{"type":"close#18"}}'
21045 / 0
21068 + java -jar cli-artemis-jms/target/cli-artemis-jms-1.2.2-SNAPSHOT-LATEST.jar receiver --log-msgs interop --count 1 --address JAMQMsgPatterns0beTestsb2EL9Rf
21068 / 0
      Show
      21045 + node bin/sender-client.js --log-lib=TRANSPORT_FRM --log-msgs interop --count 1 --msg-content-list-item --msg-content-list-item String --msg-content-list-item ~1 --msg-content-list-item ~1.0 --msg-content-list-item 1 --msg-content-list-item 1.0 --msg-content-list-item ~-1 --msg-content-list-item ~-1.3 --msg-content-list-item -1 --msg-content-list-item ~1 --msg-correlation-id corr-id-4 --address JAMQMsgPatterns0beTestsb2EL9Rf 21045 ! 2018-06-21T15:10:54.293Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":["647e0eb3-0cbf-6d49-8da2-94652e92fa1f",null,null,null,null,null,null,null,null,[]]}' 21045 ! 2018-06-21T15:10:54.300Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[null,0,2048,4294967295]}' 21045 ! 2018-06-21T15:10:54.302Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":["6a215a3e-2f6d-6c49-a65a-b8579ec17bab",0,false,null,null,[],["JAMQMsgPatterns0beTestsb2EL9Rf",0],null,null,0]}' 21045 ! 2018-06-21T15:10:55.192Z rhea:frames [connection-1] RECV: { protocol_id: 0, major: 1, minor: 0, revision: 0 } 21045 ! 2018-06-21T15:10:55.198Z rhea:frames [connection-1] RECV: '{"size":188,"type":0,"channel":0,"performative":{"type":"open#10","container_id":"amq","max_frame_size":131072,"channel_max":65535,"idle_time_out":30000,"offered_capabilities":["sole-connection-for-container","DELAYED_DELIVERY","SHARED-SUBS","ANONYMOUS-RELAY"],"properties":{"product":"apache-activemq-artemis","version":"2.6.1.amq-720003-redhat-1"}}}' 21045 ! 2018-06-21T15:10:55.212Z rhea:frames [connection-1] RECV: '{"size":34,"type":0,"channel":0,"performative":{"type":"begin#11","next_outgoing_id":1,"incoming_window":2147483647,"outgoing_window":2147483647,"handle_max":65535}}' 21045 ! 2018-06-21T15:10:55.213Z rhea:frames [connection-1] RECV: '{"size":100,"type":0,"channel":0,"performative":{"type":"attach#12","name":"6a215a3e-2f6d-6c49-a65a-b8579ec17bab","role":true,"snd_settle_mode":2,"source":[],"target":["JAMQMsgPatterns0beTestsb2EL9Rf"]}}' 21045 ! 2018-06-21T15:10:55.214Z rhea:frames [connection-1] RECV: '{"size":34,"type":0,"channel":0,"performative":{"type":"flow#13","incoming_window":2147483647,"next_outgoing_id":1,"outgoing_window":2147483647,"link_credit":1000}}' 21045 {"durable":False,"priority":None,"ttl":None,"first-acquirer":None,"delivery-count":0,"id":None,"user-id":None,"address":"JAMQMsgPatterns0beTestsb2EL9Rf","subject":None,"reply-to":None,"correlation-id":"corr-id-4","content-type":"string","content-encoding":None,"absolute-expiry-time":None,"creation-time":None,"group-id":None,"group-sequence":None,"reply-to-group-id":None,"properties":None,"content":["","String",1,1,"1","1.0",-1,-1.3,"-1",1]} 21045 ! 2018-06-21T15:10:55.252Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[0,0,{"type":"Buffer","data":[48]},0,false,false],"payload":{"type":"Buffer","data":[0,83,112,208,0,0,0,9,0,0,0,5,66,64,64,64,67,0,83,114,209,0,0,0,4,0,0,0,0,0,83,115,208,0,0,0,65,0,0,0,13,64,64,161,30,74,65,77,81,77,115,103,80,97,116,116,101,114,110,115,48,98,101,84,101,115,116,115,98,50,69,76,57,82,102,64,64,161,9,99,111,114,114,45,105,100,45,52,163,6,115,116,114,105,110,103,64,64,64,64,64,64,0,83,116,209,0,0,0,4,0,0,0,0,0,83,119,208,0,0,0,43,0,0,0,10,161,0,161,6,83,116,114,105,110,103,82,1,82,1,161,1,49,161,3,49,46,48,84,255,130,191,244,204,204,204,204,204,205,161,2,45,49,82,1]}}' 21045 ! 2018-06-21T15:10:55.355Z rhea:frames [connection-1] RECV: '{"size":22,"type":0,"channel":0,"performative":{"type":"disposition#15","role":true,"settled":true,"state":[]}}' 21045 ! 2018-06-21T15:10:55.356Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[0,false]}' 21045 ! 2018-06-21T15:10:55.356Z rhea:frames [connection-1] PENDING: '{"channel":0,"type":0,"performative":[]}' 21045 ! 2018-06-21T15:10:55.382Z rhea:frames [connection-1] RECV: '{"size":15,"type":0,"channel":0,"performative":{"type":"detach#16"}}' 21045 ! 2018-06-21T15:10:55.383Z rhea:frames [connection-1] RECV: '{"size":12,"type":0,"channel":0,"performative":{"type":"close#18"}}' 21045 / 0 21068 + java -jar cli-artemis-jms/target/cli-artemis-jms-1.2.2-SNAPSHOT-LATEST.jar receiver --log-msgs interop --count 1 --address JAMQMsgPatterns0beTestsb2EL9Rf 21068 / 0

      cli-rhea likes the uint, and this is one case that conversions on broker cannot handle. Other qe clis would use signed int here and the problem would not arise.

      2018-06-21 17:10:58,181 WARN  [org.apache.activemq.artemis.core.server] AMQ222151: removing consumer which did not handle a message, consumer=ServerConsumerImpl [id=0, filter=null, binding=LocalQueueBinding [address=JAMQMsgPatterns0beTestsb2EL9Rf, queue=QueueImpl[name=JAMQMsgPatterns0beTestsb2EL9Rf, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=3d02313e-754f-11e8-bf4d-2201c4a6b177], temp=false]@341500ad, filter=null, name=JAMQMsgPatterns0beTestsb2EL9Rf, clusterName=JAMQMsgPatterns0beTestsb2EL9Rf3d02313e-754f-11e8-bf4d-2201c4a6b177]], message=Reference[524]:NON-RELIABLE:AMQPMessage [durable=false, messageID=524, address=JAMQMsgPatterns0beTestsb2EL9Rf, size=168, applicationProperties=ApplicationProperties{{}}, properties=Properties{messageId=null, userId=null, to='JAMQMsgPatterns0beTestsb2EL9Rf', subject='null', replyTo='null', correlationId=corr-id-4, contentType=string, contentEncoding=null, absoluteExpiryTime=null, creationTime=null, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[_AMQ_AD=JAMQMsgPatterns0beTestsb2EL9Rf]]: java.lang.RuntimeException: Invalid object type: class org.apache.qpid.proton.amqp.UnsignedInteger
	at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:1206) [artemis-amqp-protocol-2.6.1.amq-720003-redhat-1.jar:]
	at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1106) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:464) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2938) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2406) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$2000(QueueImpl.java:107) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:3211) [artemis-server-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_152-release]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_152-release]
	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.6.1.amq-720003-redhat-1.jar:2.6.1.amq-720003-redhat-1]
Caused by: javax.jms.MessageFormatException: Invalid object type: class org.apache.qpid.proton.amqp.UnsignedInteger
	at org.apache.activemq.artemis.protocol.amqp.converter.jms.ServerJMSStreamMessage.writeObject(ServerJMSStreamMessage.java:299) [artemis-amqp-protocol-2.6.1.amq-720003-redhat-1.jar:]
	at org.apache.activemq.artemis.protocol.amqp.converter.AmqpCoreConverter.toCore(AmqpCoreConverter.java:159) [artemis-amqp-protocol-2.6.1.amq-720003-redhat-1.jar:]
	at org.apache.activemq.artemis.protocol.amqp.converter.AMQPConverter.toCore(AMQPConverter.java:43) [artemis-amqp-protocol-2.6.1.amq-720003-redhat-1.jar:]
	at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:1204) [artemis-amqp-protocol-2.6.1.amq-720003-redhat-1.jar:]
	... 13 more

              rh-ee-ataylor Andy Taylor
              jdanek@redhat.com Jiri Daněk
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated: