Hi,
I am new to activeMQ. I facing a problem while running activeMQ. Every
alternate message posted on queue is not reaching to the Listener.
I am using tomcat 5.5.9 with activeMQ 5.2
I am using QueuePoster class to post the messages to the queue and
QueueListener to receive the messages. JMSfactory and queues are
configured using spring on consumer side by :
<jee:jndi-lookup id="jmsConnectionFactory"
jndi-name="jms/ConnectionFactory" resource-ref="true" />
<jee:jndi-lookup id="jmsqueue" jndi-name="jms/queue"
resource-ref="true" proxy-interface="javax.jms.Queue"/>
<bean id="container"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory"/>
<property name="messageListener" ref="listener"/>
<property name="destination" ref="jmsqueue"/>
</bean>
<bean id="listener" class="QueueListener" />
<amq:broker xmlns="http://activemq.apache.org/schema/core";
brokerName="localhost" dataDirectory="C:/data">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" memoryLimit="5mb"/>
</policyEntries>
</policyMap>
</destinationPolicy>
<persistenceAdapter>
<amqPersistenceAdapter syncOnWrite="false"
directory="C:/data" maxFileLength="20 mb"/>
</persistenceAdapter>
<transportConnectors>
<transportConnector brokerName="localhost"
uri="tcp://localhost:61616"/>
</transportConnectors>
</amq:broker>
Producer Configuration:
<jee:jndi-lookup id="jmsConnectionFactory"
jndi-name="jms/ConnectionFactory" resource-ref="true" />
<jee:jndi-lookup id="jmsqueue" jndi-name="jms/queue"
resource-ref="true" proxy-interface="javax.jms.Queue"/>
Problem I am facing is that every alternate message posted in getting
dropped and is not reaching the Listener. I am able to validate
through logs that the message is posted successfully every time
without any exception but Listener is invoked only for alternate
messages posted on the queue.
Can someone please help me understand where I am going wrong with this
configuration.
Regards
Sandeep
