Loading...

XML

Word

Printable

Details

Type: Bug
Resolution: Done
Priority: Critical
Fix Version/s: A-MQ 7.0.0.ER16
Affects Version/s: A-MQ 7.0.0.ER15
Component/s: None
Labels:
None

Affects:

Release Notes
Target Release:

A-MQ 7.0.0.GA
Steps to Reproduce:
Hide

Send a message using python amqp client with content "python sender"

/var/dtests/node_data/clients/aac5_sender.py --broker-url "admin:admin@10.34.33.213:5672/lala" --log-msgs dict --count 1 --msg-content "Python sender" --msg-content-type String [0x239dc70]: -> SASL [0x239dc70]: <- SASL [0x239dc70]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:PLAIN, :ANONYMOUS]] [0x239dc70]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\x00admin\x00admin"] [0x239dc70]:0 <- @sasl-outcome(68) [code=0] [0x239dc70]: -> AMQP [0x239dc70]:0 -> @open(16) [container-id="e3403f86-3dd6-4d8a-a474-cb5aecef2266", hostname="10.34.33.213", channel-max=32767] [0x239dc70]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x239dc70]:0 -> @attach(18) [name="e3403f86-3dd6-4d8a-a474-cb5aecef2266-lala", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [durable=0, timeout=0, dynamic=false], target=@target(41) [address="lala", durable=0, timeout=0, dynamic=false], initial-delivery-count=0] [0x239dc70]: <- AMQP [0x239dc70]:0 <- @open(16) [container-id="amq", max-frame-size=4294967295, channel-max=65535, idle-time-out=30000, offered-capabilities=@PN_SYMBOL[:"sole-connection-for-container", :"DELAYED_DELIVERY", :"SHARED-SUBS"], properties={:product="apache-activemq-artemis", :version="1.5.1.amq-700002-redhat-1"}] [0x239dc70]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1, incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535] [0x239dc70]:0 <- @attach(18) [name="e3403f86-3dd6-4d8a-a474-cb5aecef2266-lala", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [], target=@target(41) [address="lala"]] [0x239dc70]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647, next-outgoing-id=1, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=100] {'address': None, 'annotations': None, 'body': 'Python sender', 'content': 'Python sender', 'content_encoding': 'None', 'content_type': 'String', 'correlation_id': None, 'creation_time': 0.000000, 'delivery_count': 0, 'durable': False, 'expiry_time': 0.000000, 'first_acquirer': False, 'group_id': None, 'group_sequence': 0, 'id': None, 'inferred': False, 'instructions': None, 'priority': 4, 'properties': {}, 'reply_to': None, 'reply_to_group_id': None, 'subject': None, 'ttl': 0.000000, 'user_id': ''} [0x239dc70]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"1", message-format=0, settled=false, more=false] (98) "\x00Sp\xd0\x00\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00)\x00\x00\x00\x0d@@@@@@\xa3\x06String@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x00\x00\x00\x00\x00\x00@R\x00@\x00St\xd1\x00\x00\x00\x04\x00\x00\x00\x00\x00Sw\xa1\x0dPython sender" [0x239dc70]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x239dc70]:0 -> @detach(22) [handle=0, closed=true] [0x239dc70]:0 -> @close(24) [] [0x239dc70]: -> EOS [0x239dc70]:0 <- @detach(22) [handle=0, closed=true] [0x239dc70]:0 <- @close(24) [] [0x239dc70]: <- EOS

Send a message by amqp qpid-cpp client with content "cpp sender"

/var/dtests/node_data/clients/aac0_sender --log-msgs dict --broker admin:admin@10.34.33.213:5672 --connection-options "{ sasl_mechanisms : 'PLAIN', protocol : 'amqp1.0' }" --address lala --count 1 --msg-content "Cpp sender" --msg-content-type String [0x1510d70]: -> AMQP [0x1510d70]: <- AMQP [0x1510d70]:0 -> @open(16) [container-id="f5cc1698-2211-43c5-ab7c-5c4c2d11d6b6", channel-max=32767, properties={:"qpid.client_process"=:"aac0_sender", :"qpid.client_pid"=12701, :"qpid.client_ppid"=11108}] [0x1510d70]:0 <- @open(16) [container-id="amq", max-frame-size=4294967295, channel-max=65535, idle-time-out=30000, offered-capabilities=@PN_SYMBOL[:"sole-connection-for-container", :"DELAYED_DELIVERY", :"SHARED-SUBS"], properties={:product="apache-activemq-artemis", :version="1.5.1.amq-700002-redhat-1"}] [0x1510d70]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1510d70]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1, incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535] [0x1510d70]:0 -> @attach(18) [name="lala_ef71dc14-0547-439e-8107-faeb7044bc26", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="lala", durable=0, timeout=0, dynamic=false], target=@target(41) [address="lala", durable=0, timeout=0, dynamic=false], initial-delivery-count=0] [0x1510d70]:0 <- @attach(18) [name="lala_ef71dc14-0547-439e-8107-faeb7044bc26", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="lala"], target=@target(41) [address="lala"]] [0x1510d70]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647, next-outgoing-id=1, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=100] [0x1510d70]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"\x00\x00\x00\x00", message-format=0, settled=false, more=false] (56) "\x00Sp\xc0\x04\x02BP\x00\x00Ss\xd0\x00\x00\x00\x12\x00\x00\x00\x07@@@@@@\xa3\x06String\x00St\xc1\x01\x00\x00Sw\xa1\x0aCpp sender" {'redelivered': False, 'reply_to': None, 'subject': None, 'content_type': 'String', 'id': None, 'user_id': None, 'correlation_id': None, 'priority': 0, 'durable': False, 'ttl': 0.000000e+00, 'size': 10, 'properties': {}, 'content': 'Cpp sender'} [0x1510d70]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x1510d70]:0 -> @end(23) [] [0x1510d70]:0 -> @close(24) [] [0x1510d70]: -> EOS [0x1510d70]:0 <- @end(23) [] [0x1510d70]:0 <- @close(24) [] [0x1510d70]: <- EOS

Receive those messages using openwire client

java -jar /var/dtests/node_data/clients/java/aoc/target/aoc7-downstream-ga-5.11.0.redhat-630187.jar receiver --log-msgs dict --broker tcp://10.34.33.213:61616 --conn-username admin --conn-password admin --address lala --count 0 --timeout 5 13:32:13,031 DEBUG Sending: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, Host=10.34.33.213, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 13:32:13,038 DEBUG Using min of local: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, Host=10.34.33.213, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} and remote: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=false, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 13:32:13,039 DEBUG Received WireFormat: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=false, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 13:32:13,039 DEBUG tcp:///10.34.33.213:61616@60102 before negotiation: OpenWireFormat{version=10, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false, maxFrameSize=9223372036854775807} 13:32:13,039 DEBUG tcp:///10.34.33.213:61616@60102 after negotiation: OpenWireFormat{version=10, cacheEnabled=false, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false, maxFrameSize=9223372036854775807} 13:32:13,103 DEBUG Initialized TaskRunnerFactory[ActiveMQ Session Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@6977e80e[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] {'redelivered': False, 'reply_to': None, 'id': 'f5a48698-e167-11e6-9b75-525400061be7:0:0:-1', 'user_id':None, 'correlation_id': None, 'priority': 0, 'durable': False, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 0, 'address': 'queue://lala', 'properties': {'JMS_AMQP_ORIGINAL_ENCODING': 5, 'JMS_AMQP_HEADERDURABLE': True, '__AMQ_CID': 'f5cc1698-2211-43c5-ab7c-5c4c2d11d6b6', 'JMS_AMQP_HEADER': True, 'JMS_AMQP_HEADERPRIORITY': True, 'JMS_AMQP_ContentType': 'String'}, 'content': 'Cpp sender'} >>> expected message from python sender with content: "Python sender" NOK 13:32:18,128 DEBUG Received unexpected response: {Response {commandId = 0, responseRequired = false, correlationId = 8}}for command id: 8 13:32:18,129 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@6977e80e[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 1] is shutdown: true and terminated: false took: 0.000 seconds. 13:32:18,129 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@6adede5[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. 13:32:18,130 DEBUG Stopping transport tcp:///10.34.33.213:61616@60102 13:32:18,130 DEBUG Initialized TaskRunnerFactory[ActiveMQ Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@192b07fd[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] 13:32:18,130 DEBUG Closed socket Socket[addr=/10.34.33.213,port=61616,localport=60102] 13:32:18,131 DEBUG Forcing shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@192b07fd[Running, pool size = 1, active threads = 0, queued tasks = 0, completed tasks = 1]

broker.log

13:31:07,160 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-41235-1485174665004-1:1:-1 13:31:07,172 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:29,641 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:48,310 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:32:10,041 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.io.IOException: exception setting property JMSXDeliveryCount : 1 at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:772) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:205) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:235) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1020) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:416) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2641) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2142) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:103) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2873) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51] at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51] Caused by: javax.jms.MessageFormatException: Property JMSXDeliveryCount cannot be set from a java.lang.Long. at org.apache.activemq.command.ActiveMQMessage$1.set(ActiveMQMessage.java:361) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:509) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:488) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:769) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] ... 13 more 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,080 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:07,160 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-41235-1485174665004-1:1:-1 13:31:07,172 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:29,641 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:48,310 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:32:10,041 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.io.IOException: exception setting property JMSXDeliveryCount : 1 at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:772) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:205) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:235) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1020) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:416) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2641) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2142) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:103) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2873) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51] at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51] Caused by: javax.jms.MessageFormatException: Property JMSXDeliveryCount cannot be set from a java.lang.Long. at org.apache.activemq.command.ActiveMQMessage$1.set(ActiveMQMessage.java:361) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:509) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:488) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:769) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] ... 13 more 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,080 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT]
Show
Send a message using python amqp client with content "python sender" /var/dtests/node_data/clients/aac5_sender.py --broker-url "admin:admin@10.34.33.213:5672/lala" --log-msgs dict --count 1 --msg-content "Python sender" --msg-content-type String [0x239dc70]: -> SASL [0x239dc70]: <- SASL [0x239dc70]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:PLAIN, :ANONYMOUS]] [0x239dc70]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\x00admin\x00admin"] [0x239dc70]:0 <- @sasl-outcome(68) [code=0] [0x239dc70]: -> AMQP [0x239dc70]:0 -> @open(16) [container-id="e3403f86-3dd6-4d8a-a474-cb5aecef2266", hostname="10.34.33.213", channel-max=32767] [0x239dc70]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x239dc70]:0 -> @attach(18) [name="e3403f86-3dd6-4d8a-a474-cb5aecef2266-lala", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [durable=0, timeout=0, dynamic=false], target=@target(41) [address="lala", durable=0, timeout=0, dynamic=false], initial-delivery-count=0] [0x239dc70]: <- AMQP [0x239dc70]:0 <- @open(16) [container-id="amq", max-frame-size=4294967295, channel-max=65535, idle-time-out=30000, offered-capabilities=@PN_SYMBOL[:"sole-connection-for-container", :"DELAYED_DELIVERY", :"SHARED-SUBS"], properties={:product="apache-activemq-artemis", :version="1.5.1.amq-700002-redhat-1"}] [0x239dc70]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1, incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535] [0x239dc70]:0 <- @attach(18) [name="e3403f86-3dd6-4d8a-a474-cb5aecef2266-lala", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [], target=@target(41) [address="lala"]] [0x239dc70]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647, next-outgoing-id=1, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=100] {'address': None, 'annotations': None, 'body': 'Python sender', 'content': 'Python sender', 'content_encoding': 'None', 'content_type': 'String', 'correlation_id': None, 'creation_time': 0.000000, 'delivery_count': 0, 'durable': False, 'expiry_time': 0.000000, 'first_acquirer': False, 'group_id': None, 'group_sequence': 0, 'id': None, 'inferred': False, 'instructions': None, 'priority': 4, 'properties': {}, 'reply_to': None, 'reply_to_group_id': None, 'subject': None, 'ttl': 0.000000, 'user_id': ''} [0x239dc70]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"1", message-format=0, settled=false, more=false] (98) "\x00Sp\xd0\x00\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00)\x00\x00\x00\x0d@@@@@@\xa3\x06String@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x00\x00\x00\x00\x00\x00@R\x00@\x00St\xd1\x00\x00\x00\x04\x00\x00\x00\x00\x00Sw\xa1\x0dPython sender" [0x239dc70]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x239dc70]:0 -> @detach(22) [handle=0, closed=true] [0x239dc70]:0 -> @close(24) [] [0x239dc70]: -> EOS [0x239dc70]:0 <- @detach(22) [handle=0, closed=true] [0x239dc70]:0 <- @close(24) [] [0x239dc70]: <- EOS Send a message by amqp qpid-cpp client with content "cpp sender" /var/dtests/node_data/clients/aac0_sender --log-msgs dict --broker admin:admin@10.34.33.213:5672 --connection-options "{ sasl_mechanisms : 'PLAIN', protocol : 'amqp1.0' }" --address lala --count 1 --msg-content "Cpp sender" --msg-content-type String [0x1510d70]: -> AMQP [0x1510d70]: <- AMQP [0x1510d70]:0 -> @open(16) [container-id="f5cc1698-2211-43c5-ab7c-5c4c2d11d6b6", channel-max=32767, properties={:"qpid.client_process"=:"aac0_sender", :"qpid.client_pid"=12701, :"qpid.client_ppid"=11108}] [0x1510d70]:0 <- @open(16) [container-id="amq", max-frame-size=4294967295, channel-max=65535, idle-time-out=30000, offered-capabilities=@PN_SYMBOL[:"sole-connection-for-container", :"DELAYED_DELIVERY", :"SHARED-SUBS"], properties={:product="apache-activemq-artemis", :version="1.5.1.amq-700002-redhat-1"}] [0x1510d70]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1510d70]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1, incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535] [0x1510d70]:0 -> @attach(18) [name="lala_ef71dc14-0547-439e-8107-faeb7044bc26", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="lala", durable=0, timeout=0, dynamic=false], target=@target(41) [address="lala", durable=0, timeout=0, dynamic=false], initial-delivery-count=0] [0x1510d70]:0 <- @attach(18) [name="lala_ef71dc14-0547-439e-8107-faeb7044bc26", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="lala"], target=@target(41) [address="lala"]] [0x1510d70]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647, next-outgoing-id=1, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=100] [0x1510d70]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"\x00\x00\x00\x00", message-format=0, settled=false, more=false] (56) "\x00Sp\xc0\x04\x02BP\x00\x00Ss\xd0\x00\x00\x00\x12\x00\x00\x00\x07@@@@@@\xa3\x06String\x00St\xc1\x01\x00\x00Sw\xa1\x0aCpp sender" {'redelivered': False, 'reply_to': None, 'subject': None, 'content_type': 'String', 'id': None, 'user_id': None, 'correlation_id': None, 'priority': 0, 'durable': False, 'ttl': 0.000000e+00, 'size': 10, 'properties': {}, 'content': 'Cpp sender'} [0x1510d70]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x1510d70]:0 -> @end(23) [] [0x1510d70]:0 -> @close(24) [] [0x1510d70]: -> EOS [0x1510d70]:0 <- @end(23) [] [0x1510d70]:0 <- @close(24) [] [0x1510d70]: <- EOS Receive those messages using openwire client java -jar /var/dtests/node_data/clients/java/aoc/target/aoc7-downstream-ga-5.11.0.redhat-630187.jar receiver --log-msgs dict --broker tcp://10.34.33.213:61616 --conn-username admin --conn-password admin --address lala --count 0 --timeout 5 13:32:13,031 DEBUG Sending: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, Host=10.34.33.213, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 13:32:13,038 DEBUG Using min of local: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, Host=10.34.33.213, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} and remote: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=false, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 13:32:13,039 DEBUG Received WireFormat: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true, CacheEnabled=false, TightEncodingEnabled=true, MaxFrameSize=9223372036854775807, MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000}, magic=[A,c,t,i,v,e,M,Q]} 13:32:13,039 DEBUG tcp:///10.34.33.213:61616@60102 before negotiation: OpenWireFormat{version=10, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false, maxFrameSize=9223372036854775807} 13:32:13,039 DEBUG tcp:///10.34.33.213:61616@60102 after negotiation: OpenWireFormat{version=10, cacheEnabled=false, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false, maxFrameSize=9223372036854775807} 13:32:13,103 DEBUG Initialized TaskRunnerFactory[ActiveMQ Session Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@6977e80e[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] {'redelivered': False, 'reply_to': None, 'id': 'f5a48698-e167-11e6-9b75-525400061be7:0:0:-1', 'user_id':None, 'correlation_id': None, 'priority': 0, 'durable': False, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 0, 'address': 'queue://lala', 'properties': {'JMS_AMQP_ORIGINAL_ENCODING': 5, 'JMS_AMQP_HEADERDURABLE': True, '__AMQ_CID': 'f5cc1698-2211-43c5-ab7c-5c4c2d11d6b6', 'JMS_AMQP_HEADER': True, 'JMS_AMQP_HEADERPRIORITY': True, 'JMS_AMQP_ContentType': 'String'}, 'content': 'Cpp sender'} >>> expected message from python sender with content: "Python sender" NOK 13:32:18,128 DEBUG Received unexpected response: {Response {commandId = 0, responseRequired = false, correlationId = 8}}for command id: 8 13:32:18,129 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@6977e80e[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 1] is shutdown: true and terminated: false took: 0.000 seconds. 13:32:18,129 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@6adede5[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. 13:32:18,130 DEBUG Stopping transport tcp:///10.34.33.213:61616@60102 13:32:18,130 DEBUG Initialized TaskRunnerFactory[ActiveMQ Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@192b07fd[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] 13:32:18,130 DEBUG Closed socket Socket[addr=/10.34.33.213,port=61616,localport=60102] 13:32:18,131 DEBUG Forcing shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@192b07fd[Running, pool size = 1, active threads = 0, queued tasks = 0, completed tasks = 1] broker.log 13:31:07,160 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-41235-1485174665004-1:1:-1 13:31:07,172 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:29,641 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:48,310 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:32:10,041 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.io.IOException: exception setting property JMSXDeliveryCount : 1 at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:772) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:205) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:235) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1020) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:416) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2641) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2142) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:103) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2873) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51] at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51] Caused by: javax.jms.MessageFormatException: Property JMSXDeliveryCount cannot be set from a java.lang.Long. at org.apache.activemq.command.ActiveMQMessage$1.set(ActiveMQMessage.java:361) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:509) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:488) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:769) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] ... 13 more 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,080 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:07,160 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-41235-1485174665004-1:1:-1 13:31:07,172 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:29,641 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:31:48,310 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 13:32:10,041 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.io.IOException: exception setting property JMSXDeliveryCount : 1 at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:772) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:205) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:235) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1020) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:416) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2641) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2142) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:103) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2873) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51] at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51] Caused by: javax.jms.MessageFormatException: Property JMSXDeliveryCount cannot be set from a java.lang.Long. at org.apache.activemq.command.ActiveMQMessage$1.set(ActiveMQMessage.java:361) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:509) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:488) [activemq-client-5.11.0.redhat-630187.jar:5.11.0.redhat-630187] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:769) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:] ... 13 more 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,067 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session f59c4934-e167-11e6-9b75-525400061be7 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,068 WARN [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:jaguar-36507-1485174732919-1:1:-1 13:32:15,080 WARN [org.apache.activemq.artemis.core.server] AMQ222067: Connection failure has been detected: null [code=REMOTE_DISCONNECT]

SFDC Cases Counter:
SFDC Cases Links:

Description

When python-client sends an AMQP message to broker, the Openwire (jms) client is unable to receive it. It seems by broker log, that broker is unable to convert message from AMQP to Openwire.

13:32:10,041 WARN  [org.apache.activemq.artemis.core.server] Error during message dispatch: java.io.IOException: exception setting property JMSXDeliveryCount : 1
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:772) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:419) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:205) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:235) [artemis-openwire-protocol-1.5.1.amq-700002-redhat-1.jar:]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1020) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:416) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2641) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2142) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:103) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2873) [artemis-server-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:101) [artemis-commons-1.5.1.amq-700002-redhat-1.jar:1.5.1.amq-700002-redhat-1]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
        at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
Caused by: javax.jms.MessageFormatException: Property JMSXDeliveryCount cannot be set from a java.lang.Long.

Actually when I am thinking about it more, it might be a python client library bug as well, as both AMQP clients (java/jms & qpid-cpp) works well with broker and openwire client. jross@redhat.com could you please have a look on this as well?
PS: I tested manually with python-proton 0.14, but it fails with 0.16 libraries in our CI as well.
Thank you

Edit: I don't think this is a regression, as in jboss-a-mq-6.3.0.redhat-211, I am not able to receive message delivered by any AMQP client via openwire jms client. All of them failed on

Error message from Openwire client reading message from python/Qpid JMS senders:
Error while printing content from message
javax.jms.MessageFormatException: malformed input around byte 3
	at org.apache.activemq.util.JMSExceptionSupport.createMessageFormatException(JMSExceptionSupport.java:95)
	at org.apache.activemq.command.ActiveMQBytesMessage.readUTF(ActiveMQBytesMessage.java:455)
	at com.redhat.mqe.jms.MessageFormatter.formatContent(MessageFormatter.java:280)
	at com.redhat.mqe.jms.MessageFormatter.printMessageAsDict(MessageFormatter.java:57)
	at com.redhat.mqe.jms.CoreClient.printMessage(CoreClient.java:382)
	at com.redhat.mqe.jms.ReceiverClient.consumeMessage(ReceiverClient.java:185)
	at com.redhat.mqe.jms.ReceiverClient.startClient(ReceiverClient.java:107)
	at com.redhat.mqe.jms.aoc7_receiver.main(aoc7_receiver.java:30)
	at com.redhat.mqe.jms.Main.main(Main.java:29)
Caused by: java.io.UTFDataFormatException: malformed input around byte 3
	at java.io.DataInputStream.readUTF(DataInputStream.java:634)
	at java.io.DataInputStream.readUTF(DataInputStream.java:564)
	at org.apache.activemq.command.ActiveMQBytesMessage.readUTF(ActiveMQBytesMessage.java:451)

==== from qpid-cpp sender is a bit different
java -jar /var/dtests/node_data/clients/aoc7.jar receiver --log-msgs dict --broker tcp://localhost:61616 --conn-username admin --conn-password admin --address lala --count 0 --timeout 5
Error while printing content from message
javax.jms.MessageEOFException: java.io.EOFException
	at org.apache.activemq.util.JMSExceptionSupport.createMessageEOFException(JMSExceptionSupport.java:84)
	at org.apache.activemq.command.ActiveMQBytesMessage.readUTF(ActiveMQBytesMessage.java:453)
	at com.redhat.mqe.jms.MessageFormatter.formatContent(MessageFormatter.java:280)
	at com.redhat.mqe.jms.MessageFormatter.printMessageAsDict(MessageFormatter.java:57)
	at com.redhat.mqe.jms.CoreClient.printMessage(CoreClient.java:382)
	at com.redhat.mqe.jms.ReceiverClient.consumeMessage(ReceiverClient.java:185)
	at com.redhat.mqe.jms.ReceiverClient.startClient(ReceiverClient.java:107)
	at com.redhat.mqe.jms.aoc7_receiver.main(aoc7_receiver.java:30)
	at com.redhat.mqe.jms.Main.main(Main.java:29)
Caused by: java.io.EOFException
	at java.io.DataInputStream.readFully(DataInputStream.java:197)
	at java.io.DataInputStream.readUTF(DataInputStream.java:609)
	at java.io.DataInputStream.readUTF(DataInputStream.java:564)
	at org.apache.activemq.command.ActiveMQBytesMessage.readUTF(ActiveMQBytesMessage.java:451)
	... 7 more

Attachments

Issue Links

relates to: ARTEMIS-944 Loading...

Activity

People

Assignee:: Andy Taylor

Reporter:: Michal Toth

Tester:: Jiri Daněk

Votes:: 0 Vote for this issue

Watchers:: 4 Start watching this issue

Dates

Created:: 2017/01/23 7:46 AM

Updated:: 2021/10/24 5:39 AM

Resolved:: 2017/05/19 4:11 AM