[
https://issues.apache.org/jira/browse/QPID-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robbie Gemmell updated QPID-6388:
---------------------------------
Attachment: QPID-6388-reproducer.tar.gz
Attaching a reproducer. It opens/creates the subscription, sends one message,
closes the subscriber, sends another message. On the first first it should log
out 1 message, on subsequent runs it should log out both the 'offline' message
and the next new one it sends.
Steps to use:
1. Check out the new client source from:
https://git-wip-us.apache.org/repos/asf/qpid-jms.git or
https://github.com/apache/qpid-jms
2. Extract the attachment somewhere.
3. Apply the change in the client_change.diff file to the client checkout.
4. Run "mvn clean install -DskipTests" in the client checkout.
5. Start the broker, created a topic exchange called "MY_TOPIC".
6. Run "mvn verify" once in the reproducer dir, notice it log out the initial
Hello World message.
7. Run "mvn verify" a second time in the reproducer dir, watch the broker
console for the exception.
> [Java Broker] [AMQP 1.0] unable to resubscribe a durable subscription link
> when using 'configuration' terminus durability
> -------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-6388
> URL: https://issues.apache.org/jira/browse/QPID-6388
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker
> Affects Versions: 0.31
> Reporter: Robbie Gemmell
> Attachments: QPID-6388-reproducer.tar.gz
>
>
> 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.
> {noformat}
> 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
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
