Restarting the broker that has Durable subscriptions

["Claude Montpetit [Trilliant]" <cl...@trilliantnetworks.com>]

Hi,

I have an activemq 4 (snapshot march 23rd). I am launching a durable 
topic consumer in Spring using lingo. The first time I run the client on 
the active broker, all works just fine. I shutdown both processes (the 
broker and the consumer), and I restart them both. Then, I get an 
exception in both that says that the durable subscription is already active.

1- Is this a normal behavior? Is it a bug?

2- How can I  "reset" activemq? Where does it persist this state 
information by default? I want to run a clean activemq.

Here is my config
:
  <bean id="someService" 
class="org.logicblaze.lingo.jms.JmsServiceExporter">
    <property name="service" ref="someServiceImpl"/>
    <property name="serviceInterface" value="com.someCompany.SomeService"/>
    <property name="connectionFactory" ref="jmsFactory"/>
    <property name="destination" ref="someServiceTopic"/>
    <property name="invocationFactory" ref="invocationFactory"/>     
    <property name="clientID" value="someService-consumer1"/>
    <property name="subscriberName" value="someService-consumer1"/>
  </bean>

And the exception:
Exception in thread "main" 
org.springframework.beans.factory.BeanCreationException:
  Error creating bean with name 'someService' defined in
  class path resource [com/someCompany/server-applicationContext.xml]:
Invocation of init method failed; nested exception is 
javax.jms.JMSException:
  That durable subscription is already active.
javax.jms.JMSException: That durable subscription is already active.
        at 
org.apache.activemq.broker.region.TopicRegion.createSubscription(Topi
cRegion.java:205)
        at 
org.apache.activemq.broker.jmx.ManagedTopicRegion.createSubscription(
ManagedTopicRegion.java:44)
        at 
org.apache.activemq.broker.region.TopicRegion.createDestination(Topic
Region.java:170)
        at 
org.apache.activemq.broker.jmx.ManagedTopicRegion.createDestination(M
anagedTopicRegion.java:56)
        at 
org.apache.activemq.broker.region.AbstractRegion.addDestination(Abstr
actRegion.java:76)
        at 
org.apache.activemq.broker.region.RegionBroker.addDestination(RegionB
roker.java:194)
        at 
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.j
ava:124)
        at 
org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBr
oker.java:139)
        at 
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.j
ava:124)
        at 
org.apache.activemq.broker.MutableBrokerFilter.addDestination(Mutable
BrokerFilter.java:136)
        at 
org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegio
n.java:215)
        at 
org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion
.java:66)
        at 
org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBrok
er.java:261)
        at 
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java
:68)
        at 
org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroke
r.java:75)
        at 
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java
:68)
        at 
org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBro
kerFilter.java:80)
        at 
org.apache.activemq.broker.AbstractConnection.processAddConsumer(Abst
ractConnection.java:422)
        at 
org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:291)

        at 
org.apache.activemq.broker.AbstractConnection.service(AbstractConnect
ion.java:196)
        at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC
onnection.java:62)
        at 
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCo
rrelator.java:88)
        at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt
er.java:70)
        at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireForm
atNegotiator.java:114)
        at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityM
onitor.java:122)
        at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSup
port.java:87)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
136)
        at java.lang.Thread.run(Thread.java:595)