2 Replies Latest reply on Dec 9, 2009 2:48 AM by alesj

    JBoss-Spring-ActiveMQ integration issue

      I am using Spring2.5.5, ActiveMQ5.3, JBoss 5.1.

      I am using 10 concurrent cousumers in DefaultMessageListenerContainer









      I have tried with "cacheLevelName" property with None,Session,Connection
      The problem is that only one consumer gets invoked. I have tested it.


      Can somebody help me? I want
      1. if 10 messages (huge) come to my queue, the all the 10 consumers get invoked and complete the process
      2. how can I increase this number as my number of messages consumers increase ,since in ActiveMQ console I am just seeing fixed number of consumers. i.e. how to pool ?

        • 1. Re: JBoss-Spring-ActiveMQ integration issue

          --------------------------------------------------------------------------------

          I am using Spring2.5.5, ActiveMQ5.3, JBoss 5.1.

          I am using 10 concurrent cousumers in DefaultMessageListenerContainer

          <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMes sageListenerContainer">
          <property name="connectionFactory" ref="MyCF" />
          <property name="destination" ref="MyPostQueue" />
          <property name="messageListener" ref="MyPojo" />
          <property name="sessionTransacted" value="true"/>
          <property name="concurrentConsumers" value="10"/>
          <property name="cacheLevelName" value="CACHE_CONSUMER" />
          </bean>








          I have tried with "cacheLevelName" property with None,Session,Connection
          The problem is that only one consumer gets invoked. I have tested it.


          Can somebody help me? I want
          1. if 10 messages (huge) come to my queue, the all the 10 consumers get invoked and complete the process
          2. how can I increase this number as my number of messages consumers increase ,since in ActiveMQ console I am just seeing fixed number of consumers. i.e. how to pool ?



          • 2. Re: JBoss-Spring-ActiveMQ integration issue
            alesj