0 Replies Latest reply on Nov 14, 2011 1:24 AM by mmkrishna2008

AciveMQ5.3 is unable to dispatch messages to consumer

mmkrishna2008 Nov 14, 2011 1:24 AM

We are able to post messages to queue but consumer is not able to consume messages.

Only after restarting ActiveMQ consumer started reading the messages..

We have two activemq instances in cluster.. please refer the attached configuration file

Persistence is disabled..

Please refer the below logs....

2011-08-12 01:38:55,232 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@139d891

2011-08-12 01:38:55,238 | WARN | Could not start network bridge between: vm://null and: tcp://messagebrokerqueue1:61616 due to: java.net.ConnectException: Connection refused | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@139d891

2011-08-12 01:39:25,741 | INFO | Establishing network connection from vm://null to tcp://messagebrokerqueue1:61616 | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@988dd6

2011-08-12 01:39:25,741 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@988dd6

2011-08-12 01:39:25,746 | WARN | Could not start network bridge between: vm://null and: tcp://messagebrokerqueue1:61616 due to: java.net.ConnectException: Connection refused | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@988dd6

2011-08-12 01:39:56,258 | INFO | Establishing network connection from vm://null to tcp://messagebrokerqueue1:61616 | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@19a0c4e

2011-08-12 01:39:56,260 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@19a0c4e

2011-08-12 01:39:56,264 | WARN | Could not start network bridge between: vm://null and: tcp://messagebrokerqueue1:61616 due to: java.net.ConnectException: Connection refused | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@19a0c4e

2011-08-12 01:40:26,762 | INFO | Establishing network connection from vm://null to tcp://messagebrokerqueue1:61616 | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@16068c9

2011-08-12 01:40:26,763 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@16068c9

2011-08-12 01:40:26,767 | WARN | Could not start network bridge between: vm://null and: tcp://messagebrokerqueue1:61616 due to: java.net.ConnectException: Connection refused | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@16068c9

2011-08-12 01:40:57,243 | INFO | Establishing network connection from vm://null to tcp://messagebrokerqueue1:61616 | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@2f892f

2011-08-12 01:40:57,244 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@2f892f

2011-08-12 01:40:57,262 | WARN | Could not start network bridge between: vm://null and: tcp://messagebrokerqueue1:61616 due to: java.net.ConnectException: Connection refused | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@2f892f

2011-08-12 01:41:27,746 | INFO | Establishing network connection from vm://null to tcp://messagebrokerqueue1:61616 | org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@3e3c83

2011-08-12 01:41:27,748 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | Simple Discovery Agent: java.util.concurrent.ThreadPoolExecutor$Worker@3e3c83

2011-08-12 01:41:27,787 | INFO | Network connection between vm://localhost#36 and tcp://messagebrokerqueue1/10.31.171.16:61616(Activemq_1) has been established. | org.apache.activemq.network.DemandForwardingBridge | StartLocalBridge: localBroker=vm://localhost#36

2011-08-12 02:58:42,039 | INFO | Slow KahaDB access: cleanup took 1101 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 03:01:17,202 | INFO | Slow KahaDB access: cleanup took 634 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 04:58:43,224 | INFO | Slow KahaDB access: cleanup took 601 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 05:58:43,197 | INFO | Slow KahaDB access: cleanup took 962 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 12:58:42,942 | INFO | Slow KahaDB access: cleanup took 850 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 13:58:45,283 | INFO | Slow KahaDB access: cleanup took 1821 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 19:58:42,521 | INFO | Slow KahaDB access: cleanup took 1040 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 20:58:43,094 | INFO | Slow KahaDB access: cleanup took 1618 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-12 22:58:42,897 | INFO | Slow KahaDB access: cleanup took 1856 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-13 01:00:05,112 | INFO | Slow KahaDB access: cleanup took 509 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-13 10:41:53,458 | INFO | Slow KahaDB access: cleanup took 539 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-13 14:42:49,242 | INFO | Slow KahaDB access: cleanup took 710 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-13 20:58:42,337 | INFO | Slow KahaDB access: cleanup took 1643 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-14 10:58:42,771 | INFO | Slow KahaDB access: cleanup took 739 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-14 21:58:41,979 | INFO | Slow KahaDB access: cleanup took 1604 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-14 22:58:41,780 | INFO | Slow KahaDB access: cleanup took 989 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-08-14 23:58:42,108 | INFO | Slow KahaDB access: cleanup took 624 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-11-09 17:14:16,098 | INFO | Using Persistence Adapter: org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter@1cbda0a | org.apache.activemq.broker.BrokerService | main

2011-11-09 17:14:17,209 | INFO | Replayed 1 operations from the journal in 0.012 seconds. | org.apache.activemq.store.kahadb.MessageDatabase | main

2011-11-09 17:14:17,222 | INFO | ActiveMQ 5.3.0 JMS Message Broker (Activemq_2) is starting | org.apache.activemq.broker.BrokerService | main

2011-11-09 17:14:17,222 | INFO | For help or more information please see: http://activemq.apache.org/ | org.apache.activemq.broker.BrokerService | main

2011-11-09 17:14:18,030 | INFO | Listening for connections at: tcp://messagebrokerqueue:61616 | org.apache.activemq.transport.TransportServerThreadSupport | main

2011-11-09 17:14:18,031 | INFO | Connector openwire Started | org.apache.activemq.broker.TransportConnector | main

2011-11-09 17:14:18,031 | INFO | Establishing network connection from vm://null to tcp://messagebrokerqueue1:61616 | org.apache.activemq.network.DiscoveryNetworkConnector | main

2011-11-09 17:14:18,138 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | main

2011-11-09 17:14:18,139 | INFO | Connector vm://null Started | org.apache.activemq.broker.TransportConnector | main

2011-11-09 17:14:18,206 | INFO | Network Connector default-nc Started | org.apache.activemq.network.NetworkConnector | main

2011-11-09 17:14:18,206 | INFO | ActiveMQ JMS Message Broker (Activemq_2, ID:wso2wsas2-57365-1320858857291-0:0) started | org.apache.activemq.broker.BrokerService | main

2011-11-09 17:14:18,327 | INFO | Network connection between vm://null#0 and tcp://messagebrokerqueue1/10.31.171.16:61616(Activemq_1) has been established. | org.apache.activemq.network.DemandForwardingBridge | StartLocalBridge: localBroker=vm://null#0

2011-11-09 17:14:18,449 | INFO | Logging to org.slf4j.impl.JCLLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog | org.mortbay.log | main

2011-11-09 17:14:18,461 | INFO | jetty-6.1.9 | org.mortbay.log | main

2011-11-09 17:14:19,545 | INFO | ActiveMQ WebConsole initialized. | org.apache.activemq.web.WebConsoleStarter | main

2011-11-09 17:14:19,791 | INFO | Initializing Spring FrameworkServlet 'dispatcher' | /admin | main

2011-11-09 17:14:19,863 | INFO | ActiveMQ Console at http://0.0.0.0:8161/admin | org.mortbay.log | main

2011-11-09 17:14:20,223 | INFO | Initializing Spring root WebApplicationContext | /camel | main

2011-11-09 17:14:21,830 | WARN | Broker localhost not started so using Activemq_2 instead | org.apache.activemq.broker.BrokerRegistry | main

2011-11-09 17:14:21,830 | INFO | Connector vm://localhost Started | org.apache.activemq.broker.TransportConnector | main

2011-11-09 17:14:23,341 | INFO | Camel Console at http://0.0.0.0:8161/camel | org.mortbay.log | main

2011-11-09 17:14:23,440 | INFO | ActiveMQ Web Demos at http://0.0.0.0:8161/demo | org.mortbay.log | main

2011-11-09 17:14:23,531 | INFO | RESTful file access application at http://0.0.0.0:8161/fileserver | org.mortbay.log | main

2011-11-09 17:14:23,574 | INFO | Started SelectChannelConnector@0.0.0.0:8161 | org.mortbay.log | main

2011-11-09 18:30:05,219 | INFO | Slow KahaDB access: cleanup took 527 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

2011-11-09 19:10:07,146 | INFO | Slow KahaDB access: cleanup took 530 | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal Checkpoint Worker

We are not able to reproduce this issue.. Help us to resolve this issue

Thanks,

krish

activemq.xml 5.6 KB