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

    AciveMQ5.3 is unable to dispatch messages to consumer

    murali krishna Newbie

      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 | 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