Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Message-ID: <1113021381.1236949121754.JavaMail.jira@brutus>
Date: Fri, 13 Mar 2009 05:58:41 -0700 (PDT)
From: "Gary Tully (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Assigned: (AMQ-2144) Can't unsubscribe a durable
 subscription when there's a virtual topic present on the broker
In-Reply-To: <1622677766.1235676960005.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable


     [ https://issues.apache.org/activemq/browse/AMQ-2144?page=3Dcom.atlass=
ian.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 pre=
sent 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=C3=A1udio 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 t=
ime 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.regio=
n.Topic
> javax.jms.JMSException: org.apache.activemq.broker.region.virtual.Virtual=
TopicInterceptor cannot be cast to org.apache.activemq.broker.region.Topic
> =09at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSup=
port.java:49)
> =09at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConne=
ction.java:1244)
> =09at org.apache.activemq.ActiveMQConnection.unsubscribe(ActiveMQConnecti=
on.java:2052)
> =09at org.apache.activemq.ActiveMQSession.unsubscribe(ActiveMQSession.jav=
a:1431)
> =09at DurableSubscriber.consumeMessagesAndClose(DurableSubscriber.java:20=
6)
> =09at DurableSubscriber.run(DurableSubscriber.java:112)
> =09at DurableSubscriber.main(DurableSubscriber.java:70)
> Caused by: java.lang.ClassCastException: org.apache.activemq.broker.regio=
n.virtual.VirtualTopicInterceptor cannot be cast to org.apache.activemq.bro=
ker.region.Topic
> =09at org.apache.activemq.broker.region.TopicRegion.removeSubscription(To=
picRegion.java:139)
> =09at org.apache.activemq.broker.region.RegionBroker.removeSubscription(R=
egionBroker.java:409)
> =09at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFi=
lter.java:98)
> =09at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFi=
lter.java:98)
> =09at org.apache.activemq.broker.BrokerFilter.removeSubscription(BrokerFi=
lter.java:98)
> =09at org.apache.activemq.broker.MutableBrokerFilter.removeSubscription(M=
utableBrokerFilter.java:105)
> =09at org.apache.activemq.broker.TransportConnection.processRemoveSubscri=
ption(TransportConnection.java:339)
> =09at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubs=
criptionInfo.java:83)
> =09at org.apache.activemq.broker.TransportConnection.service(TransportCon=
nection.java:305)
> =09at org.apache.activemq.broker.TransportConnection$1.onCommand(Transpor=
tConnection.java:179)
> =09at org.apache.activemq.transport.TransportFilter.onCommand(TransportFi=
lter.java:68)
> =09at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFo=
rmatNegotiator.java:143)
> =09at org.apache.activemq.transport.InactivityMonitor.onCommand(Inactivit=
yMonitor.java:206)
> =09at org.apache.activemq.transport.TransportSupport.doConsume(TransportS=
upport.java:84)
> =09at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.j=
ava:203)
> =09at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.jav=
a:185)
> =09at java.lang.Thread.run(Thread.java:619)
> The error happens on the following method of org.apache.activemq.broker.r=
egion.TopicRegion class:
>     public void removeSubscription(ConnectionContext context, RemoveSubsc=
riptionInfo info) throws Exception {
>         SubscriptionKey key =3D new SubscriptionKey(info.getClientId(), i=
nfo.getSubscriptionName());
>         DurableTopicSubscription sub =3D durableSubscriptions.get(key);
>         if (sub =3D=3D null) {
>             throw new InvalidDestinationException("No durable subscriptio=
n exists for: " + info.getSubscriptionName());
>         }
>         if (sub.isActive()) {
>             throw new JMSException("Durable consumer is in use");
>         }
>         durableSubscriptions.remove(key);
>         synchronized (destinationsMutex) {
>             for (Iterator<Destination> iter =3D destinations.values().ite=
rator(); iter.hasNext();) {
>                 Topic topic =3D (Topic)iter.next();
>                 topic.deleteSubscription(context, key);
>             }
>         }
>         super.removeConsumer(context, sub.getConsumerInfo());
>     }
> The virtual topic is present on the destinations collection being iterate=
d 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.

--=20
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.