[QPID-6388] [Java Broker] [AMQP 1.0] unable to resubscribe a durable subscription link when using 'configuration' terminus durability

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.31
• Fix Version/s: 0.31
• Component/s: Broker-J
• Assignee: Robert Godfrey
• Reporter: Robbie Gemmell
• Created: 12/Feb/15 13:16
• Updated: 19/Mar/15 12:23
• Resolved: 13/Feb/15 10:17

Description

If I modify the new client to use 'configuration' terminus durability for its DurableSubscription links, it is only able to open a subscriber once, subsequent attemps result in the following output on the broker console.

00 53 12 c0 97 07 a1 05 6d 79 53 75 62 43 41 50 00 
50 00 00 53 28 c0 80 0b a1 08 4d 59 5f 54 4f 50 49 
43 52 01 a3 05 6e 65 76 65 72 43 42 40 a3 04 63 6f 
70 79 40 00 53 27 c0 03 02 41 42 e0 4e 04 a3 12 61 
6d 71 70 3a 61 63 63 65 70 74 65 64 3a 6c 69 73 74 
12 61 6d 71 70 3a 72 65 6a 65 63 74 65 64 3a 6c 69 
73 74 12 61 6d 71 70 3a 72 65 6c 65 61 73 65 64 3a 
6c 69 73 74 12 61 6d 71 70 3a 6d 6f 64 69 66 69 65 
64 3a 6c 69 73 74 e0 08 01 a3 05 74 6f 70 69 63 00 
53 29 45 
org.apache.qpid.server.util.ConnectionScopedRuntimeException: org.apache.qpid.server.message.MessageSource$ConsumerAccessRefused
	at org.apache.qpid.server.protocol.v1_0.SendingLink_1_0.<init>(SendingLink_1_0.java:394)
	at org.apache.qpid.server.protocol.v1_0.Session_1_0.remoteLinkCreation(Session_1_0.java:209)
	at org.apache.qpid.server.protocol.v1_0.Connection_1_0$2$1.run(Connection_1_0.java:167)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:360)
	at org.apache.qpid.server.protocol.v1_0.Connection_1_0$2.remoteLinkCreation(Connection_1_0.java:162)
	at org.apache.qpid.amqp_1_0.transport.SessionEndpoint.receiveAttach(SessionEndpoint.java:308)
	at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.receiveAttach(ConnectionEndpoint.java:633)
	at org.apache.qpid.amqp_1_0.type.transport.Attach.invoke(Attach.java:352)
	at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.receive(ConnectionEndpoint.java:802)
	at org.apache.qpid.amqp_1_0.framing.FrameHandler.parse(FrameHandler.java:241)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL$4.run(ProtocolEngine_1_0_0_SASL.java:384)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL$4.run(ProtocolEngine_1_0_0_SASL.java:380)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:360)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL.received(ProtocolEngine_1_0_0_SASL.java:379)
	at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL.received(ProtocolEngine_1_0_0_SASL.java:66)
	at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:153)
	at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:51)
	at org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:161)
	at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.qpid.server.message.MessageSource$ConsumerAccessRefused
	at org.apache.qpid.server.queue.AbstractQueue.addConsumer(AbstractQueue.java:653)
	at org.apache.qpid.server.queue.AbstractQueue.addConsumer(AbstractQueue.java:96)
	at org.apache.qpid.server.protocol.v1_0.SendingLink_1_0.<init>(SendingLink_1_0.java:377)
	... 20 more