In AMQ7.0 beta can't read from the queue using recv.py.

Issue

• Testing python class(send and recv). These are taken from link[1].
• If we send large number of messages around 1000000 and receive them like

python send.py -a localhost:5672/jms.queue.ex2 -m 1000000
# wait for it to end
python recv.py -a localhost:5672/jms.queue.ex2 -m 1000000
# starts working but at somepoint stops and i get that exception

• While receiving around 75k out of 1000000 messages, we get following error.

16:03:56,850 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=jms.queue.ex4, queue=QueueImpl[name=jms.queue.ex4, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=6ec953a9-cc1b-11e6-a214-da072f5c0dec]]@5d489dcd, filter=null, name=jms.queue.ex4, clusterName=jms.queue.ex46ec953a9-cc1b-11e6-a214-da072f5c0dec]], message=PagedReferenceImpl [position=PagePositionImpl [pageNr=3, messageNr=0, recordID=-1], message=PagedMessageImpl [queueIDs=[3076915], transactionID=-1, message=ServerMessage[messageID=3753733,durable=false,userID=null,priority=4, bodySize=1024, timestamp=0,expiration=0, durable=false, address=jms.queue.ex4,properties=TypedProperties[JMS_AMQP_NATIVE=true,NATIVE_MESSAGE_ID=AMQP_ULONG:76724,JMS_AMQP_FirstAcquirer=false,JMSXDeliveryCount=0,JMSXGroupSeq=0,JMS_AMQP_MESSAGE_FORMAT=0]]@540739317], deliveryTime=0, persistedCount=0, deliveryCount=1, subscription=PageSubscriptionImpl [cursorId=3076915, queue=QueueImpl[name=jms.queue.ex4, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=6ec953a9-cc1b-11e6-a214-da072f5c0dec]]@5d489dcd, filter = null]]: java.lang.IllegalStateException: Can't deliver message ActiveMQAMQPInternalErrorException[errorType=INTERNAL_ERROR message=Unknown constructor]
    at org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.sendMessage(ProtonSessionIntegrationCallback.java:474) [artemis-amqp-protocol-1.3.0.amq-700005-redhat-1.jar:]
    at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1043) [artemis-server-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:417) [artemis-server-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2507) [artemis-server-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:1999) [artemis-server-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1500(QueueImpl.java:99) [artemis-server-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2748) [artemis-server-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:103) [artemis-core-client-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_77]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_77]
    at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_77]
Caused by: ActiveMQAMQPInternalErrorException[errorType=INTERNAL_ERROR message=Unknown constructor]
    at org.proton.plug.context.server.ProtonServerSenderContext.deliverMessage(ProtonServerSenderContext.java:433) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    at org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.sendMessage(ProtonSessionIntegrationCallback.java:467) [artemis-amqp-protocol-1.3.0.amq-700005-redhat-1.jar:]
    ... 10 more
Caused by: org.apache.qpid.proton.codec.DecodeException: Unknown constructor
    at org.apache.qpid.proton.codec.DecoderImpl.readObject(DecoderImpl.java:883) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.qpid.proton.codec.DecoderImpl.readConstructor(DecoderImpl.java:62) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.qpid.proton.codec.DecoderImpl.readObject(DecoderImpl.java:880) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.qpid.proton.codec.DecoderImpl.readConstructor(DecoderImpl.java:62) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.qpid.proton.codec.DecoderImpl.readObject(DecoderImpl.java:880) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.qpid.proton.message.impl.MessageImpl.decode(MessageImpl.java:672) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.qpid.proton.message.impl.MessageImpl.decode(MessageImpl.java:574) [proton-j-0.12.0.redhat-1.jar:0.12.0.redhat-1]
    at org.apache.activemq.artemis.core.protocol.proton.converter.message.AMQPNativeOutboundTransformer.transform(AMQPNativeOutboundTransformer.java:43) [artemis-amqp-protocol-1.3.0.amq-700005-redhat-1.jar:]
    at org.apache.activemq.artemis.core.protocol.proton.converter.ProtonMessageConverter.outbound(ProtonMessageConverter.java:99) [artemis-amqp-protocol-1.3.0.amq-700005-redhat-1.jar:]
    at org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.encodeMessage(ProtonSessionIntegrationCallback.java:281) [artemis-amqp-protocol-1.3.0.amq-700005-redhat-1.jar:]
    at org.proton.plug.context.server.ProtonServerSenderContext.deliverMessage(ProtonServerSenderContext.java:429) [artemis-proton-plug-1.3.0.amq-700005-redhat-1.jar:1.3.0.amq-700005-redhat-1]
    ... 11 more

• Even if we restart broker multiple times, issue still remains.
• It is observed that while receiving if we set count to 50K than error is not seen.
• While we still can send messages to other queues.

1. https://qpid.apache.org/releases/qpid-proton-0.10/proton/python/tutorial/tutorial.html#asynchronous-send-and-receive