[BUG] Exclusive queue can not be used form other connection

Start by reproducing the durable subscriber case with a RabbitMQ service, as suggested in the issue. Inspect the AMQSession.createDurableSubscriber path and the logged exclusive-queue error; done when a test establishes whether this response is expected and documents or fixes the behavior.

Question

We need to check this response is right or not, we could make a test with RabbitMQ service.

Error Log

Exception in thread “main” javax.jms.JMSException: Error registering consumer: org.apache.qpid.AMQChannelClosedException: Error: Exclusive queue can not be used form other connection, queueName: ‘clientid:Sub1’ [error code 405: Already exists]
	at org.apache.qpid.client.AMQSession.toJMSException(AMQSession.java:3774)
	at org.apache.qpid.client.AMQSession$6.execute(AMQSession.java:2164)
	at org.apache.qpid.client.AMQSession$6.execute(AMQSession.java:2118)
	at org.apache.qpid.client.AMQConnectionDelegate_8_0.executeRetrySupport(AMQConnectionDelegate_8_0.java:416)
	at org.apache.qpid.client.AMQConnection.executeRetrySupport(AMQConnection.java:809)
	at org.apache.qpid.client.failover.FailoverRetrySupport.execute(FailoverRetrySupport.java:90)
	at org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:2116)
	at org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:1044)
	at org.apache.qpid.client.AMQSession.createDurableSubscriber(AMQSession.java:1197)
	at org.apache.qpid.client.AMQSession.createDurableSubscriber(AMQSession.java:1076)
	at com.testJms.TopicSubscriber.runTest(TopicSubscriber.java:36)
	at com.testJms.TopicSubscriber.main(TopicSubscriber.java:19)
Caused by: org.apache.qpid.AMQChannelClosedException: Error: Exclusive queue can not be used form other connection, queueName: ‘clientid:Sub1’ [error code 405: Already exists]
	at org.apache.qpid.client.handler.ChannelCloseMethodHandler.methodReceived(ChannelCloseMethodHandler.java:97)
	at org.apache.qpid.client.handler.ClientMethodDispatcherImpl.dispatchChannelClose(ClientMethodDispatcherImpl.java:198)
	at org.apache.qpid.framing.ChannelCloseBody.execute(ChannelCloseBody.java:102)
	at org.apache.qpid.client.state.AMQStateManager.methodReceived(AMQStateManager.java:118)
	at org.apache.qpid.client.AMQProtocolHandler.methodBodyReceived(AMQProtocolHandler.java:530)
	at org.apache.qpid.client.protocol.AMQProtocolSession.methodFrameReceived(AMQProtocolSession.java:446)
	at org.apache.qpid.framing.AMQMethodBodyImpl.handle(AMQMethodBodyImpl.java:64)
	at org.apache.qpid.client.AMQProtocolHandler.received(AMQProtocolHandler.java:480)
	at org.apache.qpid.client.AMQConnectionDelegate_8_0$ReceiverClosedWaiter.received(AMQConnectionDelegate_8_0.java:549)
	at org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:164)
	at java.lang.Thread.run(Thread.java:748)