activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Torsten Mielke (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQ-1862) Master broker is down when slave broker is crashed
Date Thu, 25 Feb 2010 09:58:40 GMT

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


Mime
View raw message