Hi,
We're setting up 2 embedded brokers that are networked for redundancy.
Using Active MQ 5.1 snapshot, we're able to send messages to a queue and
have them processed. It's a low volume queue ( ~50 messages per day ) with
long running jobs ( 1 hr each job ). With 25 remote consumers, the jobs
will be process successfully for a day or so and then the queue size will
start to grow but the consumers are all idle. JConsole shows messages on
the queue but when trying to view the messages it shows there are no
messages on the queue. Eventually, the queue size will continue to grow and
it appears messages start to get lost on the second or third day.
Has anyone seen similar behavior or have any suggestions?
Here are the broker configurations::
<amq:broker brokerName="BrokerA" useJmx="true" persistent="true">
<!-- Use this if we wanted to network brokers -->
<amq:networkConnectors>
<amq:networkConnector
uri="static:(tcp://machine2.mydomain.com:61616)"
dynamicOnly="true" conduitSubscriptions="false" networkTTL="5"
prefetchSize="1" decreaseNetworkConsumerPriority="false"/>
</amq:networkConnectors>
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter
directory="/var/cache/tomcat5/work/activemq-data" maxFileLength="10485760"/>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:61616"/>
</amq:transportConnectors>
</amq:broker>
<amq:broker brokerName="BrokerB" useJmx="true" persistent="true">
<!-- Use this if we wanted to network brokers -->
<amq:networkConnectors>
<amq:networkConnector
uri="static:(tcp://machine1.mydomain.com:61616)"
dynamicOnly="true" conduitSubscriptions="false" networkTTL="5"
prefetchSize="1" decreaseNetworkConsumerPriority="false"/>
</amq:networkConnectors>
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter
directory="/var/cache/tomcat5/work/activemq-data" maxFileLength="10485760"/>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:61616"/>
</amq:transportConnectors>
</amq:broker>
<!-- JMS ConnectionFactory to use, configuring to connect to embedded
broker -->
<amq:connectionFactory id="connectionFactory"
brokerURL="failover://(tcp://brokers.mydomain.com:61616)?initialReconnectDelay=10">
<amq:prefetchPolicy>
<amq:prefetchPolicy queuePrefetch="1" topicPrefetch="1"/>
</amq:prefetchPolicy>
</amq:connectionFactory>
<!-- consumer -->
<bean id="messageListener"
class="com.mycompany.searchutils.jms.SearchIndexConsumer" />
<jms:listener-container container-type="default" acknowledge="auto"
connection-factory="connectionFactory" concurrency="1"
destination-type="queue">
<jms:listener
destination="com.mycompany.searchutils.search-index-queue"
ref="messageListener"/>
</jms:listener-container>
--
View this message in context:
http://www.nabble.com/Messages-not-getting-dispatched-tp15683418s2354p15683418.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
