-
Bug
-
Resolution: Done
-
Major
-
AMQ 7.4.4.GA
-
None
-
-
+
-
Previously, if an message-driven bean used the ActiveMQ JCA RA (e.g. in Red Hat EAP) to create a durable topic subscription the MDB would fail to deploy. This issue is now resolved.
-
Verified in a release
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]
- clones
-
-
- Closed
-