You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Cláudio de Miranda Luz (JIRA)" <ji...@apache.org> on 2009/02/26 20:36:00 UTC
[jira] Created: (AMQ-2144) Can't unsubscribe a durable subscription
when there's a virtual topic present on the broker
Can't unsubscribe a durable subscription when there's a virtual topic present on the broker
-------------------------------------------------------------------------------------------
Key: AMQ-2144
URL: https://issues.apache.org/activemq/browse/AMQ-2144
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.2.0
Environment: Ubuntu
Reporter: Cláudio de Miranda Luz
The scenario is:
There's a virtual topic being used. (i.e. topic VirtualTopic.Orders).
A consumer subscribes to any topic present on the broker and after some time it tries to unsubscribe the durable subscription.
When it calls session.unsubscribe(consumerName) to unsubscribe a durable subscription, it receives the following exception:
Caught: javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1244)
at org.apache.activemq.ActiveMQConnection.unsubscribe(ActiveMQConnection.java:2052)
at org.apache.activemq.ActiveMQSession.unsubscribe(ActiveMQSession.java:1431)
at DurableSubscriber.consumeMessagesAndClose(DurableSubscriber.java:206)
at DurableSubscriber.run(DurableSubscriber.java:112)
at DurableSubscriber.main(DurableSubscriber.java:70)
Caused by: java.lang.ClassCastException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:139)
at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:409)
at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(MutableBrokerFilter.java:105)
at org.apache.activemq.broker.TransportConnection.processRemoveSubscription(TransportConnection.java:339)
at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:83)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
at java.lang.Thread.run(Thread.java:619)
The error happens on the following method of org.apache.activemq.broker.region.TopicRegion class:
public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
DurableTopicSubscription sub = durableSubscriptions.get(key);
if (sub == null) {
throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
}
if (sub.isActive()) {
throw new JMSException("Durable consumer is in use");
}
durableSubscriptions.remove(key);
synchronized (destinationsMutex) {
for (Iterator<Destination> iter = destinations.values().iterator(); iter.hasNext();) {
Topic topic = (Topic)iter.next();
topic.deleteSubscription(context, key);
}
}
super.removeConsumer(context, sub.getConsumerInfo());
}
The virtual topic is present on the destinations collection being iterated but its type is not Topic and that is what causes the error.
If there is no virtual topics present on the broker, unsubscriptions work well.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Assigned: (AMQ-2144) Can't unsubscribe a durable
subscription when there's a virtual topic present on the broker
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully reassigned AMQ-2144:
-------------------------------
Assignee: Gary Tully
> Can't unsubscribe a durable subscription when there's a virtual topic present on the broker
> -------------------------------------------------------------------------------------------
>
> Key: AMQ-2144
> URL: https://issues.apache.org/activemq/browse/AMQ-2144
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.2.0
> Environment: Ubuntu
> Reporter: Cláudio de Miranda Luz
> Assignee: Gary Tully
> Attachments: AMQ-2144.txt
>
>
> The scenario is:
> There's a virtual topic being used. (i.e. topic VirtualTopic.Orders).
> A consumer subscribes to any topic present on the broker and after some time it tries to unsubscribe the durable subscription.
> When it calls session.unsubscribe(consumerName) to unsubscribe a durable subscription, it receives the following exception:
> Caught: javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1244)
> at org.apache.activemq.ActiveMQConnection.unsubscribe(ActiveMQConnection.java:2052)
> at org.apache.activemq.ActiveMQSession.unsubscribe(ActiveMQSession.java:1431)
> at DurableSubscriber.consumeMessagesAndClose(DurableSubscriber.java:206)
> at DurableSubscriber.run(DurableSubscriber.java:112)
> at DurableSubscriber.main(DurableSubscriber.java:70)
> Caused by: java.lang.ClassCastException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:139)
> at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:409)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(MutableBrokerFilter.java:105)
> at org.apache.activemq.broker.TransportConnection.processRemoveSubscription(TransportConnection.java:339)
> at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:83)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> at java.lang.Thread.run(Thread.java:619)
> The error happens on the following method of org.apache.activemq.broker.region.TopicRegion class:
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> durableSubscriptions.remove(key);
> synchronized (destinationsMutex) {
> for (Iterator<Destination> iter = destinations.values().iterator(); iter.hasNext();) {
> Topic topic = (Topic)iter.next();
> topic.deleteSubscription(context, key);
> }
> }
> super.removeConsumer(context, sub.getConsumerInfo());
> }
> The virtual topic is present on the destinations collection being iterated but its type is not Topic and that is what causes the error.
> If there is no virtual topics present on the broker, unsubscriptions work well.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Updated: (AMQ-2144) Can't unsubscribe a durable subscription
when there's a virtual topic present on the broker
Posted by "Giovani Seben (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Giovani Seben updated AMQ-2144:
-------------------------------
Attachment: AMQ-2144.txt
Patch and Junit test case attached.
> Can't unsubscribe a durable subscription when there's a virtual topic present on the broker
> -------------------------------------------------------------------------------------------
>
> Key: AMQ-2144
> URL: https://issues.apache.org/activemq/browse/AMQ-2144
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.2.0
> Environment: Ubuntu
> Reporter: Cláudio de Miranda Luz
> Attachments: AMQ-2144.txt
>
>
> The scenario is:
> There's a virtual topic being used. (i.e. topic VirtualTopic.Orders).
> A consumer subscribes to any topic present on the broker and after some time it tries to unsubscribe the durable subscription.
> When it calls session.unsubscribe(consumerName) to unsubscribe a durable subscription, it receives the following exception:
> Caught: javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1244)
> at org.apache.activemq.ActiveMQConnection.unsubscribe(ActiveMQConnection.java:2052)
> at org.apache.activemq.ActiveMQSession.unsubscribe(ActiveMQSession.java:1431)
> at DurableSubscriber.consumeMessagesAndClose(DurableSubscriber.java:206)
> at DurableSubscriber.run(DurableSubscriber.java:112)
> at DurableSubscriber.main(DurableSubscriber.java:70)
> Caused by: java.lang.ClassCastException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:139)
> at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:409)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(MutableBrokerFilter.java:105)
> at org.apache.activemq.broker.TransportConnection.processRemoveSubscription(TransportConnection.java:339)
> at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:83)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> at java.lang.Thread.run(Thread.java:619)
> The error happens on the following method of org.apache.activemq.broker.region.TopicRegion class:
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> durableSubscriptions.remove(key);
> synchronized (destinationsMutex) {
> for (Iterator<Destination> iter = destinations.values().iterator(); iter.hasNext();) {
> Topic topic = (Topic)iter.next();
> topic.deleteSubscription(context, key);
> }
> }
> super.removeConsumer(context, sub.getConsumerInfo());
> }
> The virtual topic is present on the destinations collection being iterated but its type is not Topic and that is what causes the error.
> If there is no virtual topics present on the broker, unsubscriptions work well.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Resolved: (AMQ-2144) Can't unsubscribe a durable
subscription when there's a virtual topic present on the broker
Posted by "Gary Tully (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gary Tully resolved AMQ-2144.
-----------------------------
Resolution: Fixed
Fix Version/s: 5.3.0
r753297 - patch applied with thanks.
> Can't unsubscribe a durable subscription when there's a virtual topic present on the broker
> -------------------------------------------------------------------------------------------
>
> Key: AMQ-2144
> URL: https://issues.apache.org/activemq/browse/AMQ-2144
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.2.0
> Environment: Ubuntu
> Reporter: Cláudio de Miranda Luz
> Assignee: Gary Tully
> Fix For: 5.3.0
>
> Attachments: AMQ-2144.txt
>
>
> The scenario is:
> There's a virtual topic being used. (i.e. topic VirtualTopic.Orders).
> A consumer subscribes to any topic present on the broker and after some time it tries to unsubscribe the durable subscription.
> When it calls session.unsubscribe(consumerName) to unsubscribe a durable subscription, it receives the following exception:
> Caught: javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> javax.jms.JMSException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
> at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1244)
> at org.apache.activemq.ActiveMQConnection.unsubscribe(ActiveMQConnection.java:2052)
> at org.apache.activemq.ActiveMQSession.unsubscribe(ActiveMQSession.java:1431)
> at DurableSubscriber.consumeMessagesAndClose(DurableSubscriber.java:206)
> at DurableSubscriber.run(DurableSubscriber.java:112)
> at DurableSubscriber.main(DurableSubscriber.java:70)
> Caused by: java.lang.ClassCastException: org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:139)
> at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:409)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFilter.java:98)
> at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(MutableBrokerFilter.java:105)
> at org.apache.activemq.broker.TransportConnection.processRemoveSubscription(TransportConnection.java:339)
> at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:83)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> at java.lang.Thread.run(Thread.java:619)
> The error happens on the following method of org.apache.activemq.broker.region.TopicRegion class:
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> durableSubscriptions.remove(key);
> synchronized (destinationsMutex) {
> for (Iterator<Destination> iter = destinations.values().iterator(); iter.hasNext();) {
> Topic topic = (Topic)iter.next();
> topic.deleteSubscription(context, key);
> }
> }
> super.removeConsumer(context, sub.getConsumerInfo());
> }
> The virtual topic is present on the destinations collection being iterated but its type is not Topic and that is what causes the error.
> If there is no virtual topics present on the broker, unsubscriptions work well.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.