Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-3692

MDB Durable Subscriber error in AMQ 7

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: AMQ 7.5.0.GA, AMQ 7.7.0.GA, AMQ 7.6.0.GA
    • Fix Version/s: AMQ 7.8.0.CR1
    • Component/s: broker-core
    • Labels:
      None
    • Target Release:
    • Release Notes Text:
      Hide
      Previously, if a message-driven bean (MDB) used the ActiveMQ Java Connector Architecture (JCA) resource adapter (for example, in Red Hat JBoss Enterprise Application Platform) to create a durable topic subscription, the MDB would fail to deploy. This issue is now resolved.
      Show
      Previously, if a message-driven bean (MDB) used the ActiveMQ Java Connector Architecture (JCA) resource adapter (for example, in Red Hat JBoss Enterprise Application Platform) to create a durable topic subscription, the MDB would fail to deploy. This issue is now resolved.
    • Release Notes Docs Status:
      Documented as Resolved Issue
    • Verified:
      Verified in a release

      Description

      I have a EAP 7.2 with a remote AMQ 7.5 broker configuration. I'm trying to create a durable topic subscriber using a MDB without success.

      Here is the activation properties of my MDB:

      • destination = MyTopic
      • subscriptionName = example
      • subscriptionDurability = Durable
      • clientID = example

      2 things to notice when I start EAP:

      • It creates an address in AMQ 7.5: MyTopic:example.example (multicast/multicast)
      • It fails with the following exception in EAP:
      ERROR [org.apache.activemq.artemis.ra] (default-threads - 1) AMQ154003: Unable to reconnect org.apache.activemq.artemis.ra.inflow.ActiveMQActivationSpec(ra=org.wildfly.extension.messaging.activemq.ActiveMQResourceAdapter@9382da9c destination=MyTopic destinationType=javax.jms.Topic ack=Auto-acknowledge durable=true clientID=example subscription=example user=null maxSession=15): ActiveMQIllegalStateException[errorType=ILLEGAL_STATE message=AMQ229025: Cannot delete queue example.example on binding example.example - it has consumers  org.apache.activemq.artemis.core.postoffice.impl.LocalQueueBinding]
        at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:423)
        at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:319)
        at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.deleteQueue(ActiveMQSessionContext.java:279)
        at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.deleteQueue(ClientSessionImpl.java:679)
      

      It also fails in AMQ side with a similar exception:

      DEBUG [org.apache.activemq.artemis.core.protocol.core.ServerSessionPacketHandler] Sending exception to client: ActiveMQIllegalStateException[errorType=ILLEGAL_STATE message=AMQ229025: Cannot delete queue example.example on binding example.example - it has consumers 
      org.apache.activemq.artemis.core.postoffice.impl.LocalQueueBinding]
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.destroyQueue(ActiveMQServerImpl.java:2163) [artemis-server-2.10.0.redhat-00004.jar:2.10.0.redhat-00004]
       

        Attachments

          Issue Links

            Activity

              People

              Assignee:
              jbertram Justin Bertram
              Reporter:
              agalvao Angelo Souza
              Tester:
              Oleg Sushchenko Oleg Sushchenko
              Votes:
              1 Vote for this issue
              Watchers:
              5 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved: