Announcement Announcement Module
Collapse
No announcement yet.
DefaultMessageListenerContainer - maxConsumers Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • DefaultMessageListenerContainer - maxConsumers

    Hello,
    in my context I use a bean with type of DefaultMessageListenerContainer.
    For properties i set :
    Code:
    <property name="concurrentConsumers" value="1" />
    <property name="maxConcurentConsumers" value="1" />
    However when i start the application i get following:
    INFO 2008-05-26 10:13:55,125 [...ListenerContainer-2] - ...
    Code:
    INFO  2008-05-26 10:13:57,587 [Thread-3] - NEW DIMENSION MANAGER BY TS: 1 (1)
    ERROR 2008-05-26 10:13:59,810 [...ListenerContainer-1] - Setup of JMS message listener invoker failed - trying to recover
    javax.jms.JMSException: Durable consumer is in use for client: BH and subscriptionName: BH
            at org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:75)
            at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:383)
            at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
            at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:83)
            at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
            at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:92)
            at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:528)
            at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:345)
            at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
            at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
            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:196)
            at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)
            at java.lang.Thread.run(Thread.java:619)
    INFO  2008-05-26 10:13:59,812 [...ListenerContainer-1] - Successfully refreshed JMS Connection
    Why do i get .ListenerContainer-1 and .ListenerContainer-2?
    I have only one message on the durable topic and i set the limits for concurent consumers.
Working...
X