Uploaded image for project: 'Qpid'
  1. Qpid
  2. QPID-6388

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

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.31
    • Fix Version/s: 0.31
    • Component/s: Broker-J
    • Labels:
      None

      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
      

        Attachments

        1. QPID-6388-reproducer.tar.gz
          3 kB
          Robbie Gemmell

          Activity

            People

            • Assignee:
              rgodfrey Robert Godfrey
              Reporter:
              robbie Robbie Gemmell
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: