Description
Found this while looking at changes for AMQNET-610. While trying to shutdown a connection the NMS amqp provider throws an exception on the transport thread.
Havret has proposed a solution in PR 29, see https://github.com/apache/activemq-nms-amqp/pull/29#issuecomment-530123108
Here is the exception:
Exception occurred: Apache.NMS.IllegalStateException: The Session is closed at Apache.NMS.AMQP.NmsSession.CheckClosed() at Apache.NMS.AMQP.NmsSession.get_AcknowledgementMode() at Apache.NMS.AMQP.NmsMessageConsumer.SetAcknowledgeCallback(InboundMessageDispatch envelope) at Apache.NMS.AMQP.NmsMessageConsumer.OnInboundMessage(InboundMessageDispatch envelope) at Apache.NMS.AMQP.NmsSession.OnInboundMessage(InboundMessageDispatch envelope) at Apache.NMS.AMQP.NmsConnection.OnInboundMessage(InboundMessageDispatch envelope) at Apache.NMS.AMQP.Provider.Failover.FailoverProvider.OnInboundMessage(InboundMessageDispatch envelope) at Apache.NMS.AMQP.Provider.Amqp.AmqpConsumer.OnMessage(IReceiverLink receiver, Message amqpMessage) at Amqp.ReceiverLink.OnTransfer(Delivery delivery, Transfer transfer, ByteBuffer buffer) at Amqp.Session.OnTransfer(Transfer transfer, ByteBuffer buffer) at Amqp.Connection.OnFrame(ByteBuffer buffer)
Attachments
Issue Links
- links to