Atomikos Forum

Using the message driven container i'll want to unsubscribe my durable topic subscription on context shutdown.

    <bean id="jmsMessageContainer" class="com.atomikos.jms.extra.MessageDrivenContainer"
        init-method="start" destroy-method="stop">
        <property name="atomikosConnectionFactoryBean" ref="jmsConnectionFactory" />
        <property name="destination" ref="testTopic" />
        <property name="messageListener" ref="jmsHome" />
        <property name="subscriberName" value="test" />
        <property name="unsubscribeOnClose" value="true" />
    </bean>

But this fails - using ActiveMQ as Provider - with this Exception:

2010-03-25 08:38:48,200 [Thread-3]      WARN  atomikos - MessageConsumerSession: unsubscribing test-0...
2010-03-25 08:38:48,222 [Thread-3]      WARN  atomikos - Error delegating call to unsubscribe on JMS driver
javax.jms.JMSException: Durable consumer is in use
    at org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:137)
    at org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:417)
    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:332)
    at org.apache.activemq.command.RemoveSubscriptionInfo.visit(RemoveSubscriptionInfo.java:83)
    at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:297)
    at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:175)
    at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
    at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
    at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:210)
    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)
2010-03-25 08:38:48,227 [Thread-3]      WARN  atomikos - atomikos connection pool 'jmsFactory1': destroying pool...


Something known about this problem - any workaround available?

Hi,

I guess the unsubscribe needs to wait for the thread to finish. This is not a very commonly used feature, but I have scheduled a bug fix for it.

Thanks

3.6.5 does wait for the thread to shutdown, but it does not close the open receiver if the thread is going to shutdown - unsubscribe still fails because the consumer is still in use.
This patch:

http://fachschaft.imn.htwk-leipzig.de/~tkrah/atomikos/MessageConsumerSession.java.patch

does fix this, which will close the receiver if there is one when the thread is going to die.

Did found some side effect of the blocking receive call.
In unit tests we have a TxTimeout of 100 - the receive call does wait 100 * 1000 / 2 - this is a long time.
Each testcase will now wait on context shutdown a long long time until thread.join() will succeed when the container is shutdown (with 3.6.5).
Thread.interrupt() maybe a way to interrupt the receive call if the Container is shutdown - but this may need more work on the code to handle the resulting JMSException gracefully - or what to do against those long long shutdown time?