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

AMQP message containing UnsignedInteger value cannot be converted to Core

    XMLWordPrintable

Details

    • 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

    Description

      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

      Attachments

        Issue Links

          is related to

          Story - Created by Jira Software - do not edit or delete. Issue type for a user story. ENTMQBR-1694 RuntimeException when converting AMQP message containing list in a property to OpenWire

          • Minor - To be worked after urgent, high, and medium priorities are resolved. This term is chosen when the severity of the issue is low, or the complexity or effort to correct it may be higher, relatively speaking. For low priority issues, known workarounds exist or are not needed due to the trivial effort needed to address the issue.
          • New

          Activity

            People

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

              Dates

                Created:
                Updated: