You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Torsten Mielke (JIRA)" <ji...@apache.org> on 2010/02/25 10:58:40 UTC
[jira] Commented: (AMQ-1862) Master broker is down when slave
broker is crashed
[ https://issues.apache.org/activemq/browse/AMQ-1862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=57859#action_57859 ]
Torsten Mielke commented on AMQ-1862:
-------------------------------------
I have noticed the same.
It was not even necessary to kill the slave, the following procedure reproduced the same behaviour using this sequence of steps:
- start the master
- start the slave
- stop the slave gracefully (CTRL+C in slave console)
- try to browse any of the master's queues. It will raise the above exception in the browser window.
We also connected JMX console to the master broker after the slave's shutdown and noticed that JMX did not show any queues anymore. However, under the Brokers MBean properties, the Queues still show up in the property called "Queues" of type javax.management.ObjectName[].
We tested using 5.3.0.5-fuse.
This kind of makes pure master/slave unusable IMHO.
> Master broker is down when slave broker is crashed
> --------------------------------------------------
>
> Key: AMQ-1862
> URL: https://issues.apache.org/activemq/browse/AMQ-1862
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.0.0, 5.1.0
> Environment: master broker(AMQ5.0) running on the Winxp+sp2 (JDK1.6)
> slave broker(AMQ5.0) running on the windows2003(JDK1.6)
> Reporter: qingwu lin
> Fix For: 5.4.0
>
>
> I have met the bugs of pure master/slave clustering on the AMQ 5.0.0. The issue is that master broker is down when I kill the slave broker ungracefully. I can't access AMQ web page(http://localhost:8161/admin/queues.jsp) and can't send any messages to MQ using "ant producer" provided by AMQ examples.
> I think that this case is very common in the production env. Thank your very much.
> Test scenarios:
> 1. Start master broker and slave broker orderly
> 2. Kill slave broker to simulate machine crash suddenly
> 3. Send a lot of messages to MQ
> ant producer
> Test result:
> master MQ throws Failed to add Connection exception and master MQ broker is down since I can not access the queue monitor page of master MQ web console.
> The error message represented on the queue page(http://localhost:8161/admin/queues.jsp):
> ==============================================================
> HTTP ERROR: 500
> java.lang.reflect.UndeclaredThrowableException
> RequestURI=/admin/queues.jsp
> Caused by:
> javax.el.ELException: java.lang.reflect.UndeclaredThrowableException
> at javax.el.BeanELResolver.getValue(BeanELResolver.java:266)
> at javax.el.CompositeELResolver.getValue(CompositeELResolver.java:143)
> at com.sun.el.parser.AstValue.getValue(AstValue.java:125)
> at com.sun.el.ValueExpressionImpl.getValue(ValueExpressionImpl.java:195)
> at org.apache.jasper.runtime.PageContextImpl.evaluateExpression(PageContextImpl.java:1008)
> at org.apache.jsp.queues_jsp._jspx_meth_c_forEach_0(org.apache.jsp.queues_jsp:139)
> at org.apache.jsp.queues_jsp._jspService(org.apache.jsp.queues_jsp:99)
> at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:80)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)
> at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:373)
> at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:464)
> at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:358)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)
> at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:487)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1098)
> at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:63)
> at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:75)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.apache.activemq.web.SessionFilter.doFilter(SessionFilter.java:46)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.apache.activemq.web.filter.ApplicationContextFilter.doFilter(ApplicationContextFilter.java:81)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at com.opensymphony.module.sitemesh.filter.PageFilter.parsePage(PageFilter.java:118)
> at com.opensymphony.module.sitemesh.filter.PageFilter.doFilter(PageFilter.java:52)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:365)
> at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
> at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:181)
> at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:712)
> at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:405)
> at org.mortbay.jetty.handler.HandlerCollection.handle(HandlerCollection.java:114)
> at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:139)
> at org.mortbay.jetty.Server.handle(Server.java:295)
> at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:503)
> at org.mortbay.jetty.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:827)
> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:511)
> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:210)
> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:379)
> at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:361)
> at org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:442)
> Caused by: java.lang.reflect.UndeclaredThrowableException
> at $Proxy21.getName(Unknown Source)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at javax.el.BeanELResolver.getValue(BeanELResolver.java:261)
> ... 39 more
> Caused by: javax.management.InstanceNotFoundException: org.apache.activemq:BrokerName=master,Type=Queue,Destination=example.A
> at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1094)
> at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getAttribute(DefaultMBeanServerInterceptor.java:662)
> at com.sun.jmx.mbeanserver.JmxMBeanServer.getAttribute(JmxMBeanServer.java:638)
> at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:263)
> ... 45 more
> Caused by:
> java.lang.reflect.UndeclaredThrowableException
> at $Proxy21.getName(Unknown Source)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at javax.el.BeanELResolver.getValue(BeanELResolver.java:261)
> at javax.el.CompositeELResolver.getValue(CompositeELResolver.java:143)
> at com.sun.el.parser.AstValue.getValue(AstValue.java:125)
> at com.sun.el.ValueExpressionImpl.getValue(ValueExpressionImpl.java:195)
> at org.apache.jasper.runtime.PageContextImpl.evaluateExpression(PageContextImpl.java:1008)
> at org.apache.jsp.queues_jsp._jspx_meth_c_forEach_0(org.apache.jsp.queues_jsp:139)
> at org.apache.jsp.queues_jsp._jspService(org.apache.jsp.queues_jsp:99)
> at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:80)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)
> at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:373)
> at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:464)
> at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:358)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)
> at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:487)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1098)
> at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:63)
> at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:75)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.apache.activemq.web.SessionFilter.doFilter(SessionFilter.java:46)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.apache.activemq.web.filter.ApplicationContextFilter.doFilter(ApplicationContextFilter.java:81)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at com.opensymphony.module.sitemesh.filter.PageFilter.parsePage(PageFilter.java:118)
> at com.opensymphony.module.sitemesh.filter.PageFilter.doFilter(PageFilter.java:52)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:365)
> at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
> at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:181)
> at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:712)
> at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:405)
> at org.mortbay.jetty.handler.HandlerCollection.handle(HandlerCollection.java:114)
> at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:139)
> at org.mortbay.jetty.Server.handle(Server.java:295)
> at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:503)
> at org.mortbay.jetty.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:827)
> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:511)
> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:210)
> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:379)
> at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:361)
> at org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:442)
> Caused by: javax.management.InstanceNotFoundException: org.apache.activemq:BrokerName=master,Type=Queue,Destination=example.A
> at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1094)
> at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getAttribute(DefaultMBeanServerInterceptor.java:662)
> at com.sun.jmx.mbeanserver.JmxMBeanServer.getAttribute(JmxMBeanServer.java:638)
> at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:263)
> ... 45 more
> Caused by:
> javax.management.InstanceNotFoundException: org.apache.activemq:BrokerName=master,Type=Queue,Destination=example.A
> at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1094)
> at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getAttribute(DefaultMBeanServerInterceptor.java:662)
> at com.sun.jmx.mbeanserver.JmxMBeanServer.getAttribute(JmxMBeanServer.java:638)
> at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:263)
> at $Proxy21.getName(Unknown Source)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:597)
> at javax.el.BeanELResolver.getValue(BeanELResolver.java:261)
> at javax.el.CompositeELResolver.getValue(CompositeELResolver.java:143)
> at com.sun.el.parser.AstValue.getValue(AstValue.java:125)
> at com.sun.el.ValueExpressionImpl.getValue(ValueExpressionImpl.java:195)
> at org.apache.jasper.runtime.PageContextImpl.evaluateExpression(PageContextImpl.java:1008)
> at org.apache.jsp.queues_jsp._jspx_meth_c_forEach_0(org.apache.jsp.queues_jsp:139)
> at org.apache.jsp.queues_jsp._jspService(org.apache.jsp.queues_jsp:99)
> at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:80)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)
> at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:373)
> at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:464)
> at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:358)
> at javax.servlet.http.HttpServlet.service(HttpServlet.java:820)
> at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:487)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1098)
> at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:63)
> at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:75)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.apache.activemq.web.SessionFilter.doFilter(SessionFilter.java:46)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.apache.activemq.web.filter.ApplicationContextFilter.doFilter(ApplicationContextFilter.java:81)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at com.opensymphony.module.sitemesh.filter.PageFilter.parsePage(PageFilter.java:118)
> at com.opensymphony.module.sitemesh.filter.PageFilter.doFilter(PageFilter.java:52)
> at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1089)
> at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:365)
> at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
> at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:181)
> at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:712)
> at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:405)
> at org.mortbay.jetty.handler.HandlerCollection.handle(HandlerCollection.java:114)
> at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:139)
> at org.mortbay.jetty.Server.handle(Server.java:295)
> at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:503)
> at org.mortbay.jetty.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:827)
> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:511)
> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:210)
> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:379)
> at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:361)
> at org.mortbay.thread.BoundedThreadPool$PoolThread.run(BoundedThreadPool.java:442)
> Powered by Jetty://
> ==============================================================
> The following error is the logs on the master broker:
> ==============================================================
> 2008-07-17 10:51:27,965 [main ] INFO BrokerService - Using Persistence Adapter: AMQPersistenceAdapter(D:\apache-activemq-5.0.0\bin\..\data\master)
> 2008-07-17 10:51:27,981 [main ] INFO BrokerService - ActiveMQ 5.0.0 JMS Message Broker (master) is starting
> 2008-07-17 10:51:27,981 [main ] INFO BrokerService - For help or more information please see: http://activemq.apache.org/
> 2008-07-17 10:51:28,028 [main ] INFO AMQPersistenceAdapter - AMQStore starting using directory: D:\apache-activemq-5.0.0\bin\..\data\master
> 2008-07-17 10:51:28,043 [JMX connector ] INFO ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
> 2008-07-17 10:51:28,059 [main ] INFO KahaStore - Kaha Store using data directory D:\apache-activemq-5.0.0\bin\..\data\master\kr-store\state
> 2008-07-17 10:51:28,106 [main ] INFO AMQPersistenceAdapter - Active data files: []
> 2008-07-17 10:51:28,324 [main ] INFO KahaStore - Kaha Store using data directory D:\apache-activemq-5.0.0\bin\..\data\master\kr-store\data
> 2008-07-17 10:51:28,340 [main ] INFO TransportServerThreadSupport - Listening for connections at: tcp://QLIN:61616
> 2008-07-17 10:51:28,340 [main ] INFO TransportConnector - Connector openwire Started
> 2008-07-17 10:51:28,340 [main ] INFO BrokerService - ActiveMQ JMS Message Broker (master, ID:QLIN-41543-1216263088199-0:0) started
> 2008-07-17 10:51:28,356 [main ] WARN BrokerRegistry - Broker localhost not started so using master instead
> 2008-07-17 10:51:28,356 [main ] INFO TransportConnector - Connector vm://localhost Started
> 2008-07-17 10:51:28,481 [main ] INFO log - Logging to org.slf4j.impl.JCLLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog
> 2008-07-17 10:51:28,496 [main ] INFO log - jetty-6.1.4
> 2008-07-17 10:51:28,762 [main ] INFO WebConsoleStarter - ActiveMQ WebConsole initialized.
> 2008-07-17 10:51:28,840 [main ] INFO /admin - Initializing Spring FrameworkServlet 'dispatcher'
> 2008-07-17 10:51:28,903 [main ] INFO log - ActiveMQ Console at http://0.0.0.0:8161/admin
> 2008-07-17 10:51:28,996 [main ] INFO log - ActiveMQ Web Demos at http://0.0.0.0:8161/demo
> 2008-07-17 10:51:29,012 [main ] INFO log - Started SelectChannelConnector@0.0.0.0:8161
> 2008-07-17 10:51:36,543 [10.0.11.35:1483] INFO TransportConnection - Slave Broker slave is attached
> 2008-07-17 10:52:23,215 [127.0.0.1:41546] ERROR Service - Async error occurred: javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Consumer.Queue.example.A does not exist.
> javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Consumer.Queue.example.A does not exist.
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:371)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:324)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:293)
> at org.apache.activemq.advisory.AdvisoryBroker.fireConsumerAdvisory(AdvisoryBroker.java:263)
> at org.apache.activemq.advisory.AdvisoryBroker.fireConsumerAdvisory(AdvisoryBroker.java:257)
> at org.apache.activemq.advisory.AdvisoryBroker.removeConsumer(AdvisoryBroker.java:222)
> at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:113)
> at org.apache.activemq.broker.MutableBrokerFilter.removeConsumer(MutableBrokerFilter.java:123)
> at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:549)
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> 2008-07-17 10:52:23,215 [nerContainer-55] ERROR efaultMessageListenerContainer - Setup of JMS message listener invoker failed - trying to recover
> javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Queue does not exist.
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:371)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:324)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:293)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:253)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:248)
> at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:149)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:141)
> at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:361)
> at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:214)
> at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:335)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:80)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
> at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:525)
> at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:334)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> 2008-07-17 10:52:23,215 [127.0.0.1:61616] WARN ActiveMQConnection - Async exception with no exception listener: javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Consumer.Queue.example.A does not exist.
> javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Consumer.Queue.example.A does not exist.
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:371)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:324)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:293)
> at org.apache.activemq.advisory.AdvisoryBroker.fireConsumerAdvisory(AdvisoryBroker.java:263)
> at org.apache.activemq.advisory.AdvisoryBroker.fireConsumerAdvisory(AdvisoryBroker.java:257)
> at org.apache.activemq.advisory.AdvisoryBroker.removeConsumer(AdvisoryBroker.java:222)
> at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:113)
> at org.apache.activemq.broker.MutableBrokerFilter.removeConsumer(MutableBrokerFilter.java:123)
> at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:549)
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> 2008-07-17 10:52:23,231 [127.0.0.1:41546] WARN Service - Failed to remove connection ConnectionInfo {commandId = 1, responseRequired = true, connectionId = ID:QLIN-41543-1216263088199-2:1, clientId = ID:QLIN-41543-1216263088199-4:0, userName = null, password = null, brokerPath = null, brokerMasterConnector = false, manageable = true, clientMaster = true}
> javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Connection does not exist.
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:371)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:324)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:293)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:253)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:248)
> at org.apache.activemq.advisory.AdvisoryBroker.removeConnection(AdvisoryBroker.java:211)
> at org.apache.activemq.broker.BrokerFilter.removeConnection(BrokerFilter.java:109)
> at org.apache.activemq.broker.MutableBrokerFilter.removeConnection(MutableBrokerFilter.java:119)
> at org.apache.activemq.broker.TransportConnection.processRemoveConnection(TransportConnection.java:697)
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:60)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> 2008-07-17 10:52:23,231 [127.0.0.1:41558] WARN TransportConnection - Failed to add Connection
> javax.jms.JMSException: The destination topic://ActiveMQ.Advisory.Connection does not exist.
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:371)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:324)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:402)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:293)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:253)
> at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:248)
> at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:75)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
> at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91)
> at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:657)
> at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)
> at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> 2008-07-17 10:52:23,231 [127.0.0.1:41558] WARN TransportConnection - Failed to add Connection
> javax.jms.InvalidClientIDException: Broker: master - Client: ID:QLIN-41543-1216263088199-4:1 already connected from /127.0.0.1:41558
> at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:205)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
> at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:72)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
> at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91)
> at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:657)
> at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)
> at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> 2008-07-17 10:52:28,231 [nerContainer-56] ERROR efaultMessageListenerContainer - Setup of JMS message listener invoker failed - trying to recover
> javax.jms.InvalidClientIDException: Broker: master - Client: ID:QLIN-41543-1216263088199-4:1 already connected from /127.0.0.1:41558
> at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:205)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
> at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:72)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81)
> at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91)
> at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:657)
> at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:86)
> at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172)
> at java.lang.Thread.run(Thread.java:619)
> .........................ignore the more exception stack by me
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.