You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@activemq.apache.org by Hiram Chirino <hi...@hiramchirino.com> on 2007/09/27 20:36:00 UTC

Please help check ActiveMQ 5.0.0 RC1

Howdy folks.

I've done the first release candidate build of activemq 5.0.0.  You can get the
binary distributions here:
http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1

Please check out this build and let me know if you see anything out of place.

-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Rob Davies <ra...@gmail.com>.

just fixing networks with duplex conections - then we can cut a RC2

On Oct 10, 2007, at 8:01 PM, Márcio Moraes wrote:

> Any ideia about next release candidate?
>
> I am testing RC1 and still get the issue of duplicate message
> https://issues.apache.org/activemq/browse/AMQ-1095
>
> Att,
>
> Márcio Moraes
>
>
> 2007/10/3, akuhtz <an...@siemens.com>:
>>
>>
>> Downloaded RC1, started bin/activemq.bat.
>> I've tried delete a durable topic subscriber via the web-console  
>> and got
>> the
>> following error:
>>
>> 2007-10-03 15:24:36,220 [btpool0-23     ] ERROR log
>> - Nested in org.springframework.web.util.NestedServletException:  
>> Request
>> processing failed; nested exception is  
>> java.lang.NullPointerException:
>> java.lang.NullPointerException
>>         at
>>
>> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSu 
>> bscriberMessageContainer
>> (KahaTopicReferenceStore.java:258)
>>         at
>>
>> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSu 
>> bscription
>> (KahaTopicReferenceStore.java:178)
>>         at
>> org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription 
>> (
>> AMQTopicMessageStore.java:193)
>>         at
>> org.apache.activemq.broker.region.Topic.deleteSubscription 
>> (Topic.java:174)
>>         at
>> org.apache.activemq.broker.region.TopicRegion.removeSubscription(
>> TopicRegion.java:137)
>>         at
>> org.apache.activemq.broker.region.RegionBroker.removeSubscription(
>> RegionBroker.java:372)
>>         at
>> org.apache.activemq.broker.jmx.BrokerView.destroyDurableSubscriber(
>> BrokerView.java:206)
>>         at
>> org.apache.activemq.web.controller.DeleteSubscriber.handleRequest(
>> DeleteSubscriber.java:38)
>>         at
>> org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.ha 
>> ndle(
>> SimpleControllerHandlerAdapter.java:48)
>>         at
>> org.springframework.web.servlet.DispatcherServlet.doDispatch(
>> DispatcherServlet.java:857)
>>         at
>> org.springframework.web.servlet.DispatcherServlet.doService(
>> DispatcherServlet.java:792)
>>         at
>> org.springframework.web.servlet.FrameworkServlet.processRequest(
>> FrameworkServlet.java:475)
>>         at
>> org.springframework.web.servlet.FrameworkServlet.doGet(
>> FrameworkServlet.java:430)
>>         at javax.servlet.http.HttpServlet.service(HttpServlet.java: 
>> 707)
>>         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)
>> 2007-10-03 15:24:36,391 [btpool0-23     ] ERROR log
>> - /admin/deleteSubscriber.action
>> java.lang.NullPointerException
>>         at
>>
>> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSu 
>> bscriberMessageContainer
>> (KahaTopicReferenceStore.java:258)
>>         at
>>
>> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSu 
>> bscription
>> (KahaTopicReferenceStore.java:178)
>>         at
>> org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription 
>> (
>> AMQTopicMessageStore.java:193)
>>         at
>> org.apache.activemq.broker.region.Topic.deleteSubscription 
>> (Topic.java:174)
>>         at
>> org.apache.activemq.broker.region.TopicRegion.removeSubscription(
>> TopicRegion.java:137)
>>         at
>> org.apache.activemq.broker.region.RegionBroker.removeSubscription(
>> RegionBroker.java:372)
>>         at
>> org.apache.activemq.broker.jmx.BrokerView.destroyDurableSubscriber(
>> BrokerView.java:206)
>>         at
>> org.apache.activemq.web.controller.DeleteSubscriber.handleRequest(
>> DeleteSubscriber.java:38)
>>         at
>> org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.ha 
>> ndle(
>> SimpleControllerHandlerAdapter.java:48)
>>         at
>> org.springframework.web.servlet.DispatcherServlet.doDispatch(
>> DispatcherServlet.java:857)
>>         at
>> org.springframework.web.servlet.DispatcherServlet.doService(
>> DispatcherServlet.java:792)
>>         at
>> org.springframework.web.servlet.FrameworkServlet.processRequest(
>> FrameworkServlet.java:475)
>>         at
>> org.springframework.web.servlet.FrameworkServlet.doGet(
>> FrameworkServlet.java:430)
>>         at javax.servlet.http.HttpServlet.service(HttpServlet.java: 
>> 707)
>>         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)
>>
>>
>>
>>
>> Hiram Chirino wrote:
>>>
>>> Howdy folks.
>>>
>>> I've done the first release candidate build of activemq 5.0.0.   
>>> You can
>>> get the
>>> binary distributions here:
>>>
>> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/ 
>> org/apache/activemq/apache-activemq/5.0.0/
>>> maven 2 repo:
>>> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
>>> maven 1 repo:
>>> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
>>>
>>> Please check out this build and let me know if you see anything  
>>> out of
>>> place.
>>>
>>> --
>>> Regards,
>>> Hiram
>>>
>>> Blog: http://hiramchirino.com
>>>
>>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Please-help-check-ActiveMQ-5.0.0-RC1- 
>> tf4530231s2354.html#a13018921
>> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>>
>>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Márcio Moraes <mm...@gmail.com>.

Any ideia about next release candidate?

I am testing RC1 and still get the issue of duplicate message
https://issues.apache.org/activemq/browse/AMQ-1095

Att,

Márcio Moraes


2007/10/3, akuhtz <an...@siemens.com>:
>
>
> Downloaded RC1, started bin/activemq.bat.
> I've tried delete a durable topic subscriber via the web-console and got
> the
> following error:
>
> 2007-10-03 15:24:36,220 [btpool0-23     ] ERROR log
> - Nested in org.springframework.web.util.NestedServletException: Request
> processing failed; nested exception is java.lang.NullPointerException:
> java.lang.NullPointerException
>         at
>
> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSubscriberMessageContainer
> (KahaTopicReferenceStore.java:258)
>         at
>
> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSubscription
> (KahaTopicReferenceStore.java:178)
>         at
> org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription(
> AMQTopicMessageStore.java:193)
>         at
> org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:174)
>         at
> org.apache.activemq.broker.region.TopicRegion.removeSubscription(
> TopicRegion.java:137)
>         at
> org.apache.activemq.broker.region.RegionBroker.removeSubscription(
> RegionBroker.java:372)
>         at
> org.apache.activemq.broker.jmx.BrokerView.destroyDurableSubscriber(
> BrokerView.java:206)
>         at
> org.apache.activemq.web.controller.DeleteSubscriber.handleRequest(
> DeleteSubscriber.java:38)
>         at
> org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.handle(
> SimpleControllerHandlerAdapter.java:48)
>         at
> org.springframework.web.servlet.DispatcherServlet.doDispatch(
> DispatcherServlet.java:857)
>         at
> org.springframework.web.servlet.DispatcherServlet.doService(
> DispatcherServlet.java:792)
>         at
> org.springframework.web.servlet.FrameworkServlet.processRequest(
> FrameworkServlet.java:475)
>         at
> org.springframework.web.servlet.FrameworkServlet.doGet(
> FrameworkServlet.java:430)
>         at javax.servlet.http.HttpServlet.service(HttpServlet.java:707)
>         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)
> 2007-10-03 15:24:36,391 [btpool0-23     ] ERROR log
> - /admin/deleteSubscriber.action
> java.lang.NullPointerException
>         at
>
> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSubscriberMessageContainer
> (KahaTopicReferenceStore.java:258)
>         at
>
> org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSubscription
> (KahaTopicReferenceStore.java:178)
>         at
> org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription(
> AMQTopicMessageStore.java:193)
>         at
> org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:174)
>         at
> org.apache.activemq.broker.region.TopicRegion.removeSubscription(
> TopicRegion.java:137)
>         at
> org.apache.activemq.broker.region.RegionBroker.removeSubscription(
> RegionBroker.java:372)
>         at
> org.apache.activemq.broker.jmx.BrokerView.destroyDurableSubscriber(
> BrokerView.java:206)
>         at
> org.apache.activemq.web.controller.DeleteSubscriber.handleRequest(
> DeleteSubscriber.java:38)
>         at
> org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.handle(
> SimpleControllerHandlerAdapter.java:48)
>         at
> org.springframework.web.servlet.DispatcherServlet.doDispatch(
> DispatcherServlet.java:857)
>         at
> org.springframework.web.servlet.DispatcherServlet.doService(
> DispatcherServlet.java:792)
>         at
> org.springframework.web.servlet.FrameworkServlet.processRequest(
> FrameworkServlet.java:475)
>         at
> org.springframework.web.servlet.FrameworkServlet.doGet(
> FrameworkServlet.java:430)
>         at javax.servlet.http.HttpServlet.service(HttpServlet.java:707)
>         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)
>
>
>
>
> Hiram Chirino wrote:
> >
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq 5.0.0.  You can
> > get the
> > binary distributions here:
> >
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> > maven 2 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > maven 1 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> >
> > Please check out this build and let me know if you see anything out of
> > place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
> >
>
> --
> View this message in context:
> http://www.nabble.com/Please-help-check-ActiveMQ-5.0.0-RC1-tf4530231s2354.html#a13018921
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>
>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by akuhtz <an...@siemens.com>.

Downloaded RC1, started bin/activemq.bat.
I've tried delete a durable topic subscriber via the web-console and got the
following error:

2007-10-03 15:24:36,220 [btpool0-23     ] ERROR log                           
- Nested in org.springframework.web.util.NestedServletException: Request
processing failed; nested exception is java.lang.NullPointerException:
java.lang.NullPointerException
	at
org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSubscriberMessageContainer(KahaTopicReferenceStore.java:258)
	at
org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSubscription(KahaTopicReferenceStore.java:178)
	at
org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription(AMQTopicMessageStore.java:193)
	at
org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:174)
	at
org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:137)
	at
org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:372)
	at
org.apache.activemq.broker.jmx.BrokerView.destroyDurableSubscriber(BrokerView.java:206)
	at
org.apache.activemq.web.controller.DeleteSubscriber.handleRequest(DeleteSubscriber.java:38)
	at
org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.handle(SimpleControllerHandlerAdapter.java:48)
	at
org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:857)
	at
org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:792)
	at
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:475)
	at
org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:430)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:707)
	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)
2007-10-03 15:24:36,391 [btpool0-23     ] ERROR log                           
- /admin/deleteSubscriber.action
java.lang.NullPointerException
	at
org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSubscriberMessageContainer(KahaTopicReferenceStore.java:258)
	at
org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSubscription(KahaTopicReferenceStore.java:178)
	at
org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription(AMQTopicMessageStore.java:193)
	at
org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:174)
	at
org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:137)
	at
org.apache.activemq.broker.region.RegionBroker.removeSubscription(RegionBroker.java:372)
	at
org.apache.activemq.broker.jmx.BrokerView.destroyDurableSubscriber(BrokerView.java:206)
	at
org.apache.activemq.web.controller.DeleteSubscriber.handleRequest(DeleteSubscriber.java:38)
	at
org.springframework.web.servlet.mvc.SimpleControllerHandlerAdapter.handle(SimpleControllerHandlerAdapter.java:48)
	at
org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:857)
	at
org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:792)
	at
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:475)
	at
org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:430)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:707)
	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)




Hiram Chirino wrote:
> 
> Howdy folks.
> 
> I've done the first release candidate build of activemq 5.0.0.  You can
> get the
> binary distributions here:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> 
> Please check out this build and let me know if you see anything out of
> place.
> 
> -- 
> Regards,
> Hiram
> 
> Blog: http://hiramchirino.com
> 
> 

-- 
View this message in context: http://www.nabble.com/Please-help-check-ActiveMQ-5.0.0-RC1-tf4530231s2354.html#a13018921
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Albert Strasheim <fu...@gmail.com>.

Hello

Firstly, thanks for all the hard work everybody is putting in to stabilise 
this release. Quite a few of my "pet bugs" have been resolved in the past 
few hours.

I'm still wondering about this one though:

Fast producer, slow consumer hangs after a few messages when using 
VMPendingSubscriberMessageStoragePolicy
https://issues.apache.org/activemq/browse/AMQ-1148

If you run the first attachment that uses a single connection with VM 
flags -Xms384m -Xmx512m you get a hang after only a few messages.

If you run the second attachment that uses separate connections for 
producers and consumers, things seem to work. However, this doesn't seem 
like a very clean solution.

Any comments on this issue would be appreciated.

Regards,

Albert

----- Original Message ----- 
From: "Hiram Chirino" <hi...@hiramchirino.com>
To: <de...@activemq.apache.org>
Sent: Thursday, September 27, 2007 8:36 PM
Subject: Please help check ActiveMQ 5.0.0 RC1


> Howdy folks.
>
> I've done the first release candidate build of activemq 5.0.0.  You can 
> get the
> binary distributions here:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo: 
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo: 
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
>
> Please check out this build and let me know if you see anything out of 
> place.
>
> -- 
> Regards,
> Hiram
>
> Blog: http://hiramchirino.com
>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Márcio Moraes <mm...@gmail.com>.

I forgot the server log:


ERROR TransportConnector             - Could not accept connection :
java.net.SocketException: Broken pipe
java.net.SocketException: Broken pipe
        at java.net.SocketOutputStream.socketWrite0(Native Method)
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java
:92)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
        at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(
TcpBufferedOutputStream.java:105)
        at java.io.DataOutputStream.flush(DataOutputStream.java:106)
        at org.apache.activemq.transport.tcp.TcpTransport.oneway(
TcpTransport.java:159)
        at org.apache.activemq.transport.InactivityMonitor.oneway(
InactivityMonitor.java:144)
        at org.apache.activemq.transport.TransportFilter.oneway(
TransportFilter.java:82)
        at org.apache.activemq.transport.WireFormatNegotiator.oneway(
WireFormatNegotiator.java:91)
        at org.apache.activemq.transport.MutexTransport.oneway(
MutexTransport.java:40)
        at org.apache.activemq.broker.TransportConnection.dispatch(
TransportConnection.java:1173)
        at org.apache.activemq.broker.TransportConnection.processDispatch(
TransportConnection.java:792)
        at org.apache.activemq.broker.TransportConnection.start(
TransportConnection.java:873)
        at org.apache.activemq.broker.TransportConnector$1$1.run(
TransportConnector.java:152)
ERROR TransportConnector             - Could not accept connection :
java.net.SocketException: Broken pipe
java.net.SocketException: Broken pipe
        at java.net.SocketOutputStream.socketWrite0(Native Method)
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java
:92)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
        at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(
TcpBufferedOutputStream.java:105)
        at java.io.DataOutputStream.flush(DataOutputStream.java:106)
        at org.apache.activemq.transport.tcp.TcpTransport.oneway(
TcpTransport.java:159)
        at org.apache.activemq.transport.InactivityMonitor.oneway(
InactivityMonitor.java:144)
        at org.apache.activemq.transport.TransportFilter.oneway(
TransportFilter.java:82)
        at org.apache.activemq.transport.WireFormatNegotiator.oneway(
WireFormatNegotiator.java:91)
        at org.apache.activemq.transport.MutexTransport.oneway(
MutexTransport.java:40)
        at org.apache.activemq.broker.TransportConnection.dispatch(
TransportConnection.java:1173)
        at org.apache.activemq.broker.TransportConnection.processDispatch(
TransportConnection.java:792)
        at org.apache.activemq.broker.TransportConnection.start(
TransportConnection.java:873)
        at org.apache.activemq.broker.TransportConnector$1$1.run(
TransportConnector.java:152)
ERROR TransportConnector             - Could not accept connection :
java.net.SocketException: Broken pipe
java.net.SocketException: Broken pipe
        at java.net.SocketOutputStream.socketWrite0(Native Method)
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java
:92)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
        at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(
TcpBufferedOutputStream.java:105)
        at java.io.DataOutputStream.flush(DataOutputStream.java:106)
        at org.apache.activemq.transport.tcp.TcpTransport.oneway(
TcpTransport.java:159)
        at org.apache.activemq.transport.InactivityMonitor.oneway(
InactivityMonitor.java:144)
        at org.apache.activemq.transport.TransportFilter.oneway(
TransportFilter.java:82)
        at org.apache.activemq.transport.WireFormatNegotiator.oneway(
WireFormatNegotiator.java:91)
        at org.apache.activemq.transport.MutexTransport.oneway(
MutexTransport.java:40)
        at org.apache.activemq.broker.TransportConnection.dispatch(
TransportConnection.java:1173)
        at org.apache.activemq.broker.TransportConnection.processDispatch(
TransportConnection.java:792)
        at org.apache.activemq.broker.TransportConnection.start(
TransportConnection.java:873)
        at org.apache.activemq.broker.TransportConnector$1$1.run(
TransportConnector.java:152)
ERROR TransportConnector             - Could not accept connection :
java.net.SocketException: Broken pipe
java.net.SocketException: Broken pipe
        at java.net.SocketOutputStream.socketWrite0(Native Method)
        at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java
:92)
        at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
        at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(
TcpBufferedOutputStream.java:105)
        at java.io.DataOutputStream.flush(DataOutputStream.java:106)
        at org.apache.activemq.transport.tcp.TcpTransport.oneway(
TcpTransport.java:159)
        at org.apache.activemq.transport.InactivityMonitor.oneway(
InactivityMonitor.java:144)
        at org.apache.activemq.transport.TransportFilter.oneway(
TransportFilter.java:82)
        at org.apache.activemq.transport.WireFormatNegotiator.oneway(
WireFormatNegotiator.java:91)
        at org.apache.activemq.transport.MutexTransport.oneway(
MutexTransport.java:40)
        at org.apache.activemq.broker.TransportConnection.dispatch(
TransportConnection.java:1173)
        at org.apache.activemq.broker.TransportConnection.processDispatch(
TransportConnection.java:792)
        at org.apache.activemq.broker.TransportConnection.start(
TransportConnection.java:873)
        at org.apache.activemq.broker.TransportConnector$1$1.run(
TransportConnector.java:152)


2007/9/27, Márcio Moraes <mm...@gmail.com>:
>
> I ran again using journal persistence with derbyds and client hangs in
> other point.
>
> I am doing a simple request/reply message with temporary topic using in
> consumer the ResourceAdapter and client jencks-amqpool
>
> The new stack trace is:
>
> [WARN ][ActiveMQ Scheduler]2007-09-27 19:03:36,998 FailoverTransport:236
> - Transport failed, attempting to automatically reconnect due to:
> org.apache.activemq.transport.InactivityIOException : Channel was inactive
> for too long.
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long.
>     at org.apache.activemq.transport.InactivityMonitor.readCheck(
> InactivityMonitor.java:100)
>     at org.apache.activemq.transport.InactivityMonitor$1.run(
> InactivityMonitor.java:50)
>     at org.apache.activemq.thread.Scheduler$SchedulerTimerTask.run(
> Scheduler.java:36)
>     at java.util.TimerThread.mainLoop (Timer.java:512)
>     at java.util.TimerThread.run(Timer.java:462)
> Full thread dump Java HotSpot(TM) Client VM (1.5.0_12-b04 mixed mode,
> sharing):
>
> "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> tid=0x081980d0 nid=0x7277 runnable [0xafb47000..0xafb47fb0]
>     at java.net.SocketInputStream.socketRead0(Native Method)
>     at java.net.SocketInputStream.read(SocketInputStream.java:129)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
> TcpBufferedInputStream.java :50)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
> TcpBufferedInputStream.java:58)
>     at java.io.DataInputStream.readInt(DataInputStream.java:353)
>     at org.apache.activemq.openwire.OpenWireFormat.unmarshal (
> OpenWireFormat.java:268)
>     at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
> TcpTransport.java:196)
>     at org.apache.activemq.transport.tcp.TcpTransport.doRun(
> TcpTransport.java:188)
>     at org.apache.activemq.transport.tcp.TcpTransport.run (
> TcpTransport.java:176)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Session Task" daemon prio=1 tid=0x0834afd8 nid=0x7229 waiting on
> condition [0xafbc8000..0xafbc8f30]
>     at sun.misc.Unsafe.park (Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (AbstractQueuedSynchronizer.java:716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (AbstractQueuedSynchronizer.java :1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask (
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Scheduler" daemon prio=1 tid=0x08835978 nid=0x7228 in
> Object.wait() [0xafc49000..0xafc49eb0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f4ffe8> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f4ffe8> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> tid=0x088352e0 nid=0x7227 waiting for monitor entry [0xafcca000..0xafccae30]
>
>     at
> org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure
> (FailoverTransport.java:236)
>     - waiting to lock <0x88f4e290> (a java.lang.Object)
>     at
> org.apache.activemq.transport.failover.FailoverTransport$2.onException (
> FailoverTransport.java:209)
>     at org.apache.activemq.transport.TransportFilter.onException(
> TransportFilter.java:98)
>     at org.apache.activemq.transport.WireFormatNegotiator.onException(
> WireFormatNegotiator.java:143)
>     at org.apache.activemq.transport.InactivityMonitor.onException(
> InactivityMonitor.java:155)
>     at org.apache.activemq.transport.TransportSupport.onException(
> TransportSupport.java:95)
>     at org.apache.activemq.transport.tcp.TcpTransport.run (
> TcpTransport.java:180)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Task" daemon prio=1 tid=0x08805cc0 nid=0x7226 runnable
> [0xafd4b000..0xafd4bdb0]
>     at java.net.SocketOutputStream.socketWrite0 (Native Method)
>     at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
>     at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
>     at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush (
> TcpBufferedOutputStream.java:105)
>     at java.io.DataOutputStream.flush(DataOutputStream.java:106)
>     at org.apache.activemq.transport.tcp.TcpTransport.oneway(
> TcpTransport.java:159)
>     at org.apache.activemq.transport.InactivityMonitor.oneway (
> InactivityMonitor.java:144)
>     - locked <0x8935abc0> (a
> org.apache.activemq.transport.InactivityMonitor$2)
>     at org.apache.activemq.transport.TransportFilter.oneway(
> TransportFilter.java:82)
>     at org.apache.activemq.transport.WireFormatNegotiator.oneway (
> WireFormatNegotiator.java:91)
>     at
> org.apache.activemq.state.ConnectionStateTracker.restoreTempDestinations(
> ConnectionStateTracker.java:173)
>     at org.apache.activemq.state.ConnectionStateTracker.restore(
> ConnectionStateTracker.java :95)
>     at
> org.apache.activemq.transport.failover.FailoverTransport.restoreTransport(
> FailoverTransport.java:525)
>     at org.apache.activemq.transport.failover.FailoverTransport$1.iterate(
> FailoverTransport.java:120)
>     - locked <0x88f4e290> (a java.lang.Object)
>     at org.apache.activemq.thread.PooledTaskRunner.runTask(
> PooledTaskRunner.java:118)
>     at org.apache.activemq.thread.PooledTaskRunner$1.run(
> PooledTaskRunner.java :42)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
> ThreadPoolExecutor.java:650)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:675)
>     at java.lang.Thread.run(Thread.java :595)
>
> "Timer-0" daemon prio=1 tid=0x087fd108 nid=0x7225 in Object.wait()
> [0xafdcc000..0xafdcd130]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f23fc0> (a java.util.TaskQueue )
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f23fc0> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "Low Memory Detector" daemon prio=1 tid=0x080abd38 nid=0x7221 runnable
> [0x00000000..0x00000000]
>
> "CompilerThread0" daemon prio=1 tid=0x080aa788 nid=0x7220 waiting on
> condition [0x00000000..0xb22d1998]
>
> "Signal Dispatcher" daemon prio=1 tid=0x080a9770 nid=0x721f runnable
> [0x00000000..0x00000000]
>
> "Finalizer" daemon prio=1 tid=0x080a2058 nid=0x721e in Object.wait()
> [0xb240d000..0xb240deb0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e8ed58> (a java.lang.ref.ReferenceQueue$Lock )
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
>     - locked <0x88e8ed58> (a java.lang.ref.ReferenceQueue$Lock)
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
>     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)
>
> "Reference Handler" daemon prio=1 tid=0x080a1318 nid=0x721d in Object.wait()
> [0xb248e000..0xb248ee30]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e8edd8> (a java.lang.ref.Reference$Lock)
>     at java.lang.Object.wait(Object.java:474)
>     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
>     - locked <0x88e8edd8> (a java.lang.ref.Reference$Lock)
>
> "main" prio=1 tid=0x080618d0 nid=0x7217 waiting on condition
> [0xbf80e000..0xbf80ed68]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park (LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await
> (AbstractQueuedSynchronizer.java:1841)
>     at java.util.concurrent.ArrayBlockingQueue.take(
> ArrayBlockingQueue.java :341)
>     at org.apache.activemq.transport.FutureResponse.getResult(
> FutureResponse.java:40)
>     at org.apache.activemq.transport.ResponseCorrelator.request(
> ResponseCorrelator.java:76)
>     at org.apache.activemq.ActiveMQConnection.syncSendPacket (
> ActiveMQConnection.java:1168)
>     at org.apache.activemq.ActiveMQConnection.createTempDestination(
> ActiveMQConnection.java:1713)
>     at org.apache.activemq.ActiveMQSession.createTemporaryTopic(
> ActiveMQSession.java:1227)
>     at org.jencks.amqpool.PooledSession.createTemporaryTopic(
> PooledSession.java:169)
>     at uol.auction.messaging.TopicMessageBroker.request(
> TopicMessageBroker.java:149)
>     at uol.auction.messaging.TopicMessageBroker.request (
> TopicMessageBroker.java:131)
>     at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
> DiagnosticMessageBrokerTest.java:46)
>     at uol.auction.domain.business.DiagnosticMessageBrokerTest.main(
> DiagnosticMessageBrokerTest.java :24)
>
> "VM Thread" prio=1 tid=0x0809fee0 nid=0x7218 runnable
>
> "VM Periodic Task Thread" prio=1 tid=0x080cea00 nid=0x7222 waiting on
> condition
>
>
> 2007/9/27, Márcio Moraes < mmoraes.br@gmail.com>:
> >
> > I ran somes testes using kaha as persistence
> >
> > My test send many messages to a consumer, after ~6000 messages client
> > hangs.
> >
> > Following is the client stack trace
> >
> > "ActiveMQ Session Task" daemon prio=1 tid=0x08878a68 nid=0x70af waiting
> > on condition [0xafa73000..0xafa73db0]
> >     at sun.misc.Unsafe.park(Native Method)
> >     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> > (AbstractQueuedSynchronizer.java :716)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> > (AbstractQueuedSynchronizer.java:771)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> > (AbstractQueuedSynchronizer.java :1099)
> >     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> > SynchronousQueue.java:265)
> >     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> > :400)
> >     at java.util.concurrent.ThreadPoolExecutor.getTask (
> > ThreadPoolExecutor.java:470)
> >     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> > ThreadPoolExecutor.java:674)
> >     at java.lang.Thread.run(Thread.java:595)
> >
> > "ActiveMQ Scheduler" daemon prio=1 tid=0x088523e8 nid=0x70ae in
> > Object.wait() [0xafaf4000..0xafaf5130]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88f57148> (a java.util.TaskQueue)
> >     at java.util.TimerThread.mainLoop(Timer.java:509)
> >     - locked <0x88f57148> (a java.util.TaskQueue)
> >     at java.util.TimerThread.run(Timer.java:462)
> >
> > "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> > tid=0x0882df60 nid=0x70ad runnable [0xafb75000..0xafb760b0]
> >     at java.net.SocketInputStream.socketRead0(Native Method)
> >     at java.net.SocketInputStream.read(SocketInputStream.java:129)
> >     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
> > TcpBufferedInputStream.java :50)
> >     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
> > TcpBufferedInputStream.java:58)
> >     at java.io.DataInputStream.readInt(DataInputStream.java:353)
> >     at org.apache.activemq.openwire.OpenWireFormat.unmarshal (
> > OpenWireFormat.java:268)
> >     at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
> > TcpTransport.java:196)
> >     at org.apache.activemq.transport.tcp.TcpTransport.doRun(
> > TcpTransport.java:188)
> >     at org.apache.activemq.transport.tcp.TcpTransport.run (
> > TcpTransport.java:176)
> >     at java.lang.Thread.run(Thread.java:595)
> >
> > "ActiveMQ Task" daemon prio=1 tid=0x0882e500 nid=0x70ac waiting on
> > condition [0xafbf6000..0xafbf7030]
> >     at sun.misc.Unsafe.park (Native Method)
> >     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> > (AbstractQueuedSynchronizer.java:716)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> > (AbstractQueuedSynchronizer.java:771)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> > (AbstractQueuedSynchronizer.java :1099)
> >     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> > SynchronousQueue.java:265)
> >     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> > :400)
> >     at java.util.concurrent.ThreadPoolExecutor.getTask (
> > ThreadPoolExecutor.java:470)
> >     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> > ThreadPoolExecutor.java:674)
> >     at java.lang.Thread.run(Thread.java:595)
> >
> > "Timer-0" daemon prio=1 tid=0x08812620 nid=0x70ab in Object.wait()
> > [0xafc77000..0xafc77fb0]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88f31158> (a java.util.TaskQueue)
> >     at java.util.TimerThread.mainLoop(Timer.java:509)
> >     - locked <0x88f31158> (a java.util.TaskQueue)
> >     at java.util.TimerThread.run(Timer.java:462)
> >
> > "ReaderThread" prio=1 tid=0x0829b5f0 nid=0x70a8 runnable
> > [0xafcf8000..0xafcf8f30]
> >     at java.net.SocketInputStream.socketRead0 (Native Method)
> >     at java.net.SocketInputStream.read(SocketInputStream.java:129)
> >     at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java
> > :411)
> >     at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java:453)
> >     at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:183)
> >     - locked <0x88ebeca0> (a java.io.InputStreamReader)
> >     at java.io.InputStreamReader.read(InputStreamReader.java:167)
> >     at java.io.BufferedReader.fill (BufferedReader.java:136)
> >     at java.io.BufferedReader.readLine(BufferedReader.java:299)
> >     - locked <0x88ebeca0> (a java.io.InputStreamReader)
> >     at java.io.BufferedReader.readLine(BufferedReader.java:362)
> >     at
> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner$ReaderThread.run(
> > RemoteTestRunner.java:140)
> >
> > "Low Memory Detector" daemon prio=1 tid=0x080ac0e0 nid=0x70a6 runnable
> > [0x00000000..0x00000000]
> >
> > "CompilerThread0" daemon prio=1 tid=0x080aab30 nid=0x70a5 waiting on
> > condition [0x00000000..0xb2265798]
> >
> > "Signal Dispatcher" daemon prio=1 tid=0x080a9ba8 nid=0x70a4 runnable
> > [0x00000000..0x00000000]
> >
> > "Finalizer" daemon prio=1 tid=0x080a23f8 nid=0x70a3 in Object.wait()
> > [0xb23a1000..0xb23a20b0]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock )
> >     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
> >     - locked <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
> >     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
> >     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)
> >
> > "Reference Handler" daemon prio=1 tid=0x080a16b8 nid=0x70a2 in
> > Object.wait() [0xb2422000..0xb2423030]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88e954b8> (a java.lang.ref.Reference$Lock)
> >     at java.lang.Object.wait(Object.java:474)
> >     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
> >     - locked <0x88e954b8> (a java.lang.ref.Reference$Lock)
> >
> > "main" prio=1 tid=0x08061c70 nid=0x709b waiting on condition
> > [0xbfd0f000..0xbfd100f8]
> >     at sun.misc.Unsafe.park(Native Method)
> >     at java.util.concurrent.locks.LockSupport.park (LockSupport.java
> > :118)
> >     at
> > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await
> > (AbstractQueuedSynchronizer.java:1841)
> >     at java.util.concurrent.ArrayBlockingQueue.take(
> > ArrayBlockingQueue.java :341)
> >     at org.apache.activemq.transport.FutureResponse.getResult(
> > FutureResponse.java:40)
> >     at org.apache.activemq.transport.ResponseCorrelator.request(
> > ResponseCorrelator.java:76)
> >     at org.apache.activemq.ActiveMQConnection.syncSendPacket (
> > ActiveMQConnection.java:1168)
> >     at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java
> > :1635)
> >     - locked <0x88f67550> (a java.lang.Object)
> >     at org.apache.activemq.ActiveMQMessageProducer.send (
> > ActiveMQMessageProducer.java:226)
> >     at org.apache.activemq.ActiveMQMessageProducerSupport.send(
> > ActiveMQMessageProducerSupport.java:299)
> >     at org.apache.activemq.ActiveMQTopicPublisher.publish(
> > ActiveMQTopicPublisher.java :171)
> >     at org.jencks.amqpool.PooledTopicPublisher.publish(
> > PooledTopicPublisher.java:50)
> >     at uol.auction.messaging.TopicMessageBroker.request(
> > TopicMessageBroker.java:154)
> >     at uol.auction.messaging.TopicMessageBroker.request (
> > TopicMessageBroker.java:131)
> >     at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
> > DiagnosticMessageBrokerTest.java:42)
> >     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:585)
> >     at junit.framework.TestCase.runTest (TestCase.java:154)
> >     at junit.framework.TestCase.runBare(TestCase.java:127)
> >     at junit.framework.TestResult$1.protect(TestResult.java:106)
> >     at junit.framework.TestResult.runProtected(TestResult.java:124)
> >     at junit.framework.TestResult.run(TestResult.java:109)
> >     at junit.framework.TestCase.run(TestCase.java:118)
> >     at junit.framework.TestSuite.runTest(TestSuite.java:208)
> >     at junit.framework.TestSuite.run ( TestSuite.java:203)
> >     at
> > org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(
> > JUnit3TestReference.java:128)
> >     at org.eclipse.jdt.internal.junit.runner.TestExecution.run(
> > TestExecution.java:38)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> > RemoteTestRunner.java:460)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> > RemoteTestRunner.java:673)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run (
> > RemoteTestRunner.java:386)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(
> > RemoteTestRunner.java:196)
> >
> > "VM Thread" prio=1 tid=0x080a0280 nid=0x70a1 runnable
> >
> > "VM Periodic Task Thread" prio=1 tid=0x080ad5d0 nid=0x70a7 waiting on
> > condition
> >
> > Att,
> >
> > Márcio Moraes
> >
> >
> > 2007/9/27, Hiram Chirino <hiram@hiramchirino.com >:
> > >
> > > Howdy folks.
> > >
> > > I've done the first release candidate build of activemq 5.0.0.  You
> > > can get the
> > > binary distributions here:
> > >
> > > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/<http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/>
> > > maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > > <http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven2>
> > > maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> > > <http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven1>
> > >
> > > Please check out this build and let me know if you see anything out of
> > > place.
> > >
> > > --
> > > Regards,
> > > Hiram
> > >
> > > Blog: http://hiramchirino.com
> > >
> >
> >
>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Márcio Moraes <mm...@gmail.com>.

I ran again using journal persistence with derbyds and client hangs in other
point.

I am doing a simple request/reply message with temporary topic using in
consumer the ResourceAdapter and client jencks-amqpool

The new stack trace is:

[WARN ][ActiveMQ Scheduler]2007-09-27 19:03:36,998 FailoverTransport:236  -
Transport failed, attempting to automatically reconnect due to:
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long.
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long.
    at org.apache.activemq.transport.InactivityMonitor.readCheck(
InactivityMonitor.java:100)
    at org.apache.activemq.transport.InactivityMonitor$1.run(
InactivityMonitor.java:50)
    at org.apache.activemq.thread.Scheduler$SchedulerTimerTask.run(
Scheduler.java:36)
    at java.util.TimerThread.mainLoop(Timer.java:512)
    at java.util.TimerThread.run(Timer.java:462)
Full thread dump Java HotSpot(TM) Client VM (1.5.0_12-b04 mixed mode,
sharing):

"ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
tid=0x081980d0 nid=0x7277 runnable [0xafb47000..0xafb47fb0]
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.read(SocketInputStream.java:129)
    at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
TcpBufferedInputStream.java:50)
    at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
TcpBufferedInputStream.java:58)
    at java.io.DataInputStream.readInt(DataInputStream.java:353)
    at org.apache.activemq.openwire.OpenWireFormat.unmarshal(
OpenWireFormat.java:268)
    at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
TcpTransport.java:196)
    at org.apache.activemq.transport.tcp.TcpTransport.doRun(
TcpTransport.java:188)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java
:176)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Session Task" daemon prio=1 tid=0x0834afd8 nid=0x7229 waiting on
condition [0xafbc8000..0xafbc8f30]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(
AbstractQueuedSynchronizer.java:716)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
(AbstractQueuedSynchronizer.java:771)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(
AbstractQueuedSynchronizer.java:1099)
    at java.util.concurrent.SynchronousQueue$Node.waitForPut(
SynchronousQueue.java:265)
    at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java:400)
    at java.util.concurrent.ThreadPoolExecutor.getTask(
ThreadPoolExecutor.java:470)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(
ThreadPoolExecutor.java:674)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Scheduler" daemon prio=1 tid=0x08835978 nid=0x7228 in Object.wait()
[0xafc49000..0xafc49eb0]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88f4ffe8> (a java.util.TaskQueue)
    at java.util.TimerThread.mainLoop(Timer.java:509)
    - locked <0x88f4ffe8> (a java.util.TaskQueue)
    at java.util.TimerThread.run(Timer.java:462)

"ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
tid=0x088352e0 nid=0x7227 waiting for monitor entry [0xafcca000..0xafccae30]
    at
org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure
(FailoverTransport.java:236)
    - waiting to lock <0x88f4e290> (a java.lang.Object)
    at
org.apache.activemq.transport.failover.FailoverTransport$2.onException(
FailoverTransport.java:209)
    at org.apache.activemq.transport.TransportFilter.onException(
TransportFilter.java:98)
    at org.apache.activemq.transport.WireFormatNegotiator.onException(
WireFormatNegotiator.java:143)
    at org.apache.activemq.transport.InactivityMonitor.onException(
InactivityMonitor.java:155)
    at org.apache.activemq.transport.TransportSupport.onException(
TransportSupport.java:95)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java
:180)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Task" daemon prio=1 tid=0x08805cc0 nid=0x7226 runnable
[0xafd4b000..0xafd4bdb0]
    at java.net.SocketOutputStream.socketWrite0(Native Method)
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
    at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
    at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(
TcpBufferedOutputStream.java:105)
    at java.io.DataOutputStream.flush(DataOutputStream.java:106)
    at org.apache.activemq.transport.tcp.TcpTransport.oneway(
TcpTransport.java:159)
    at org.apache.activemq.transport.InactivityMonitor.oneway(
InactivityMonitor.java:144)
    - locked <0x8935abc0> (a
org.apache.activemq.transport.InactivityMonitor$2)
    at org.apache.activemq.transport.TransportFilter.oneway(
TransportFilter.java:82)
    at org.apache.activemq.transport.WireFormatNegotiator.oneway(
WireFormatNegotiator.java:91)
    at
org.apache.activemq.state.ConnectionStateTracker.restoreTempDestinations(
ConnectionStateTracker.java:173)
    at org.apache.activemq.state.ConnectionStateTracker.restore(
ConnectionStateTracker.java:95)
    at
org.apache.activemq.transport.failover.FailoverTransport.restoreTransport(
FailoverTransport.java:525)
    at org.apache.activemq.transport.failover.FailoverTransport$1.iterate(
FailoverTransport.java:120)
    - locked <0x88f4e290> (a java.lang.Object)
    at org.apache.activemq.thread.PooledTaskRunner.runTask(
PooledTaskRunner.java:118)
    at org.apache.activemq.thread.PooledTaskRunner$1.run(
PooledTaskRunner.java:42)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
ThreadPoolExecutor.java:650)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(
ThreadPoolExecutor.java:675)
    at java.lang.Thread.run(Thread.java:595)

"Timer-0" daemon prio=1 tid=0x087fd108 nid=0x7225 in Object.wait()
[0xafdcc000..0xafdcd130]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88f23fc0> (a java.util.TaskQueue)
    at java.util.TimerThread.mainLoop(Timer.java:509)
    - locked <0x88f23fc0> (a java.util.TaskQueue)
    at java.util.TimerThread.run(Timer.java:462)

"Low Memory Detector" daemon prio=1 tid=0x080abd38 nid=0x7221 runnable
[0x00000000..0x00000000]

"CompilerThread0" daemon prio=1 tid=0x080aa788 nid=0x7220 waiting on
condition [0x00000000..0xb22d1998]

"Signal Dispatcher" daemon prio=1 tid=0x080a9770 nid=0x721f runnable
[0x00000000..0x00000000]

"Finalizer" daemon prio=1 tid=0x080a2058 nid=0x721e in Object.wait()
[0xb240d000..0xb240deb0]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88e8ed58> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
    - locked <0x88e8ed58> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
    at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)

"Reference Handler" daemon prio=1 tid=0x080a1318 nid=0x721d in Object.wait()
[0xb248e000..0xb248ee30]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88e8edd8> (a java.lang.ref.Reference$Lock)
    at java.lang.Object.wait(Object.java:474)
    at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
    - locked <0x88e8edd8> (a java.lang.ref.Reference$Lock)

"main" prio=1 tid=0x080618d0 nid=0x7217 waiting on condition
[0xbf80e000..0xbf80ed68]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(
AbstractQueuedSynchronizer.java:1841)
    at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java
:341)
    at org.apache.activemq.transport.FutureResponse.getResult(
FutureResponse.java:40)
    at org.apache.activemq.transport.ResponseCorrelator.request(
ResponseCorrelator.java:76)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(
ActiveMQConnection.java:1168)
    at org.apache.activemq.ActiveMQConnection.createTempDestination(
ActiveMQConnection.java:1713)
    at org.apache.activemq.ActiveMQSession.createTemporaryTopic(
ActiveMQSession.java:1227)
    at org.jencks.amqpool.PooledSession.createTemporaryTopic(
PooledSession.java:169)
    at uol.auction.messaging.TopicMessageBroker.request(
TopicMessageBroker.java:149)
    at uol.auction.messaging.TopicMessageBroker.request(
TopicMessageBroker.java:131)
    at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
DiagnosticMessageBrokerTest.java:46)
    at uol.auction.domain.business.DiagnosticMessageBrokerTest.main(
DiagnosticMessageBrokerTest.java:24)

"VM Thread" prio=1 tid=0x0809fee0 nid=0x7218 runnable

"VM Periodic Task Thread" prio=1 tid=0x080cea00 nid=0x7222 waiting on
condition


2007/9/27, Márcio Moraes <mm...@gmail.com>:
>
> I ran somes testes using kaha as persistence
>
> My test send many messages to a consumer, after ~6000 messages client
> hangs.
>
> Following is the client stack trace
>
> "ActiveMQ Session Task" daemon prio=1 tid=0x08878a68 nid=0x70af waiting on
> condition [0xafa73000..0xafa73db0]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (AbstractQueuedSynchronizer.java :716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (AbstractQueuedSynchronizer.java :1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask (
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Scheduler" daemon prio=1 tid=0x088523e8 nid=0x70ae in
> Object.wait() [0xafaf4000..0xafaf5130]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f57148> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f57148> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> tid=0x0882df60 nid=0x70ad runnable [0xafb75000..0xafb760b0]
>     at java.net.SocketInputStream.socketRead0(Native Method)
>     at java.net.SocketInputStream.read(SocketInputStream.java:129)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
> TcpBufferedInputStream.java :50)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
> TcpBufferedInputStream.java:58)
>     at java.io.DataInputStream.readInt(DataInputStream.java:353)
>     at org.apache.activemq.openwire.OpenWireFormat.unmarshal (
> OpenWireFormat.java:268)
>     at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
> TcpTransport.java:196)
>     at org.apache.activemq.transport.tcp.TcpTransport.doRun(
> TcpTransport.java:188)
>     at org.apache.activemq.transport.tcp.TcpTransport.run (
> TcpTransport.java:176)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Task" daemon prio=1 tid=0x0882e500 nid=0x70ac waiting on
> condition [0xafbf6000..0xafbf7030]
>     at sun.misc.Unsafe.park (Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (AbstractQueuedSynchronizer.java:716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (AbstractQueuedSynchronizer.java :1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask (
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "Timer-0" daemon prio=1 tid=0x08812620 nid=0x70ab in Object.wait()
> [0xafc77000..0xafc77fb0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f31158> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f31158> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ReaderThread" prio=1 tid=0x0829b5f0 nid=0x70a8 runnable
> [0xafcf8000..0xafcf8f30]
>     at java.net.SocketInputStream.socketRead0(Native Method)
>     at java.net.SocketInputStream.read(SocketInputStream.java:129)
>     at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java
> :411)
>     at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java:453)
>     at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:183)
>     - locked <0x88ebeca0> (a java.io.InputStreamReader)
>     at java.io.InputStreamReader.read(InputStreamReader.java:167)
>     at java.io.BufferedReader.fill (BufferedReader.java:136)
>     at java.io.BufferedReader.readLine(BufferedReader.java:299)
>     - locked <0x88ebeca0> (a java.io.InputStreamReader)
>     at java.io.BufferedReader.readLine(BufferedReader.java:362)
>     at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner$ReaderThread.run(
> RemoteTestRunner.java:140)
>
> "Low Memory Detector" daemon prio=1 tid=0x080ac0e0 nid=0x70a6 runnable
> [0x00000000..0x00000000]
>
> "CompilerThread0" daemon prio=1 tid=0x080aab30 nid=0x70a5 waiting on
> condition [0x00000000..0xb2265798]
>
> "Signal Dispatcher" daemon prio=1 tid=0x080a9ba8 nid=0x70a4 runnable
> [0x00000000..0x00000000]
>
> "Finalizer" daemon prio=1 tid=0x080a23f8 nid=0x70a3 in Object.wait()
> [0xb23a1000..0xb23a20b0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock )
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
>     - locked <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
>     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)
>
> "Reference Handler" daemon prio=1 tid=0x080a16b8 nid=0x70a2 in Object.wait()
> [0xb2422000..0xb2423030]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e954b8> (a java.lang.ref.Reference$Lock)
>     at java.lang.Object.wait(Object.java:474)
>     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
>     - locked <0x88e954b8> (a java.lang.ref.Reference$Lock)
>
> "main" prio=1 tid=0x08061c70 nid=0x709b waiting on condition
> [0xbfd0f000..0xbfd100f8]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park (LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await
> (AbstractQueuedSynchronizer.java:1841)
>     at java.util.concurrent.ArrayBlockingQueue.take(
> ArrayBlockingQueue.java :341)
>     at org.apache.activemq.transport.FutureResponse.getResult(
> FutureResponse.java:40)
>     at org.apache.activemq.transport.ResponseCorrelator.request(
> ResponseCorrelator.java:76)
>     at org.apache.activemq.ActiveMQConnection.syncSendPacket (
> ActiveMQConnection.java:1168)
>     at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1635)
>     - locked <0x88f67550> (a java.lang.Object)
>     at org.apache.activemq.ActiveMQMessageProducer.send (
> ActiveMQMessageProducer.java:226)
>     at org.apache.activemq.ActiveMQMessageProducerSupport.send(
> ActiveMQMessageProducerSupport.java:299)
>     at org.apache.activemq.ActiveMQTopicPublisher.publish(
> ActiveMQTopicPublisher.java :171)
>     at org.jencks.amqpool.PooledTopicPublisher.publish(
> PooledTopicPublisher.java:50)
>     at uol.auction.messaging.TopicMessageBroker.request(
> TopicMessageBroker.java:154)
>     at uol.auction.messaging.TopicMessageBroker.request (
> TopicMessageBroker.java:131)
>     at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
> DiagnosticMessageBrokerTest.java:42)
>     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:585)
>     at junit.framework.TestCase.runTest (TestCase.java:154)
>     at junit.framework.TestCase.runBare(TestCase.java:127)
>     at junit.framework.TestResult$1.protect(TestResult.java:106)
>     at junit.framework.TestResult.runProtected(TestResult.java:124)
>     at junit.framework.TestResult.run(TestResult.java:109)
>     at junit.framework.TestCase.run(TestCase.java:118)
>     at junit.framework.TestSuite.runTest(TestSuite.java:208)
>     at junit.framework.TestSuite.run( TestSuite.java:203)
>     at
> org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(
> JUnit3TestReference.java:128)
>     at org.eclipse.jdt.internal.junit.runner.TestExecution.run(
> TestExecution.java:38)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> RemoteTestRunner.java:460)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> RemoteTestRunner.java:673)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run (
> RemoteTestRunner.java:386)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(
> RemoteTestRunner.java:196)
>
> "VM Thread" prio=1 tid=0x080a0280 nid=0x70a1 runnable
>
> "VM Periodic Task Thread" prio=1 tid=0x080ad5d0 nid=0x70a7 waiting on
> condition
>
> Att,
>
> Márcio Moraes
>
>
> 2007/9/27, Hiram Chirino <hi...@hiramchirino.com>:
> >
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq 5.0.0.  You can
> > get the
> > binary distributions here:
> >
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/<http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/>
> > maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > <http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven2>
> > maven 1 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1<http://people.apache.org/%7Echirino/apache-activemq-5.0.0-RC1/maven1>
> >
> > Please check out this build and let me know if you see anything out of
> > place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>
>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Márcio Moraes <mm...@gmail.com>.

Sorry.

Connection tcp://
Consumer: Durable Topic
Persistent Message (tested with kaha and journal derby)
I am not using transaction (topicConnection.createTopicSession(false,
TopicSession.AUTO_ACKNOWLEDGE)

I am test it with other scenario.

I let you know.

Thanks

2007/9/28, Hiram Chirino <hi...@hiramchirino.com>:
>
> Hi Márcio,
>
> What usage scenario was that?  Queues, Persistent messages, over
> tcp:// using a the default broker?  Were you using transactions?
>
>
> On 9/27/07, Márcio Moraes <mm...@gmail.com> wrote:
> > I ran somes testes using kaha as persistence
> >
> > My test send many messages to a consumer, after ~6000 messages client
> hangs.
> >
> > Following is the client stack trace
> >
> > "ActiveMQ Session Task" daemon prio=1 tid=0x08878a68 nid=0x70af waiting
> on
> > condition [0xafa73000..0xafa73db0]
> >     at sun.misc.Unsafe.park(Native Method)
> >     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (
> > AbstractQueuedSynchronizer.java:716)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> > (AbstractQueuedSynchronizer.java:771)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (
> > AbstractQueuedSynchronizer.java:1099)
> >     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> > SynchronousQueue.java:265)
> >     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
> >     at java.util.concurrent.ThreadPoolExecutor.getTask(
> > ThreadPoolExecutor.java:470)
> >     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> > ThreadPoolExecutor.java:674)
> >     at java.lang.Thread.run(Thread.java:595)
> >
> > "ActiveMQ Scheduler" daemon prio=1 tid=0x088523e8 nid=0x70ae in
> Object.wait()
> > [0xafaf4000..0xafaf5130]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88f57148> (a java.util.TaskQueue)
> >     at java.util.TimerThread.mainLoop(Timer.java:509)
> >     - locked <0x88f57148> (a java.util.TaskQueue)
> >     at java.util.TimerThread.run(Timer.java:462)
> >
> > "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> > tid=0x0882df60 nid=0x70ad runnable [0xafb75000..0xafb760b0]
> >     at java.net.SocketInputStream.socketRead0(Native Method)
> >     at java.net.SocketInputStream.read(SocketInputStream.java:129)
> >     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
> > TcpBufferedInputStream.java:50)
> >     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
> > TcpBufferedInputStream.java:58)
> >     at java.io.DataInputStream.readInt(DataInputStream.java:353)
> >     at org.apache.activemq.openwire.OpenWireFormat.unmarshal(
> > OpenWireFormat.java:268)
> >     at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
> > TcpTransport.java:196)
> >     at org.apache.activemq.transport.tcp.TcpTransport.doRun(
> > TcpTransport.java:188)
> >     at org.apache.activemq.transport.tcp.TcpTransport.run(
> TcpTransport.java
> > :176)
> >     at java.lang.Thread.run(Thread.java:595)
> >
> > "ActiveMQ Task" daemon prio=1 tid=0x0882e500 nid=0x70ac waiting on
> condition
> > [0xafbf6000..0xafbf7030]
> >     at sun.misc.Unsafe.park(Native Method)
> >     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt
> (
> > AbstractQueuedSynchronizer.java:716)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> > (AbstractQueuedSynchronizer.java:771)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly
> (
> > AbstractQueuedSynchronizer.java:1099)
> >     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> > SynchronousQueue.java:265)
> >     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java
> :400)
> >     at java.util.concurrent.ThreadPoolExecutor.getTask(
> > ThreadPoolExecutor.java:470)
> >     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> > ThreadPoolExecutor.java:674)
> >     at java.lang.Thread.run(Thread.java:595)
> >
> > "Timer-0" daemon prio=1 tid=0x08812620 nid=0x70ab in Object.wait()
> > [0xafc77000..0xafc77fb0]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88f31158> (a java.util.TaskQueue)
> >     at java.util.TimerThread.mainLoop(Timer.java:509)
> >     - locked <0x88f31158> (a java.util.TaskQueue)
> >     at java.util.TimerThread.run(Timer.java:462)
> >
> > "ReaderThread" prio=1 tid=0x0829b5f0 nid=0x70a8 runnable
> > [0xafcf8000..0xafcf8f30]
> >     at java.net.SocketInputStream.socketRead0(Native Method)
> >     at java.net.SocketInputStream.read(SocketInputStream.java:129)
> >     at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java
> :411)
> >     at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java
> :453)
> >     at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:183)
> >     - locked <0x88ebeca0> (a java.io.InputStreamReader)
> >     at java.io.InputStreamReader.read(InputStreamReader.java:167)
> >     at java.io.BufferedReader.fill(BufferedReader.java:136)
> >     at java.io.BufferedReader.readLine(BufferedReader.java:299)
> >     - locked <0x88ebeca0> (a java.io.InputStreamReader)
> >     at java.io.BufferedReader.readLine(BufferedReader.java:362)
> >     at
> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner$ReaderThread.run(
> > RemoteTestRunner.java:140)
> >
> > "Low Memory Detector" daemon prio=1 tid=0x080ac0e0 nid=0x70a6 runnable
> > [0x00000000..0x00000000]
> >
> > "CompilerThread0" daemon prio=1 tid=0x080aab30 nid=0x70a5 waiting on
> > condition [0x00000000..0xb2265798]
> >
> > "Signal Dispatcher" daemon prio=1 tid=0x080a9ba8 nid=0x70a4 runnable
> > [0x00000000..0x00000000]
> >
> > "Finalizer" daemon prio=1 tid=0x080a23f8 nid=0x70a3 in Object.wait()
> > [0xb23a1000..0xb23a20b0]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
> >     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
> >     - locked <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
> >     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
> >     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)
> >
> > "Reference Handler" daemon prio=1 tid=0x080a16b8 nid=0x70a2 in
> Object.wait()
> > [0xb2422000..0xb2423030]
> >     at java.lang.Object.wait(Native Method)
> >     - waiting on <0x88e954b8> (a java.lang.ref.Reference$Lock)
> >     at java.lang.Object.wait(Object.java:474)
> >     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
> >     - locked <0x88e954b8> (a java.lang.ref.Reference$Lock)
> >
> > "main" prio=1 tid=0x08061c70 nid=0x709b waiting on condition
> > [0xbfd0f000..0xbfd100f8]
> >     at sun.misc.Unsafe.park(Native Method)
> >     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
> >     at
> >
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await
> (
> > AbstractQueuedSynchronizer.java:1841)
> >     at java.util.concurrent.ArrayBlockingQueue.take(
> ArrayBlockingQueue.java
> > :341)
> >     at org.apache.activemq.transport.FutureResponse.getResult(
> > FutureResponse.java:40)
> >     at org.apache.activemq.transport.ResponseCorrelator.request(
> > ResponseCorrelator.java:76)
> >     at org.apache.activemq.ActiveMQConnection.syncSendPacket(
> > ActiveMQConnection.java:1168)
> >     at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java
> :1635)
> >     - locked <0x88f67550> (a java.lang.Object)
> >     at org.apache.activemq.ActiveMQMessageProducer.send(
> > ActiveMQMessageProducer.java:226)
> >     at org.apache.activemq.ActiveMQMessageProducerSupport.send(
> > ActiveMQMessageProducerSupport.java:299)
> >     at org.apache.activemq.ActiveMQTopicPublisher.publish(
> > ActiveMQTopicPublisher.java:171)
> >     at org.jencks.amqpool.PooledTopicPublisher.publish(
> > PooledTopicPublisher.java:50)
> >     at uol.auction.messaging.TopicMessageBroker.request(
> > TopicMessageBroker.java:154)
> >     at uol.auction.messaging.TopicMessageBroker.request(
> > TopicMessageBroker.java:131)
> >     at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
> > DiagnosticMessageBrokerTest.java:42)
> >     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:585)
> >     at junit.framework.TestCase.runTest(TestCase.java:154)
> >     at junit.framework.TestCase.runBare(TestCase.java:127)
> >     at junit.framework.TestResult$1.protect(TestResult.java:106)
> >     at junit.framework.TestResult.runProtected(TestResult.java:124)
> >     at junit.framework.TestResult.run(TestResult.java:109)
> >     at junit.framework.TestCase.run(TestCase.java:118)
> >     at junit.framework.TestSuite.runTest(TestSuite.java:208)
> >     at junit.framework.TestSuite.run(TestSuite.java:203)
> >     at
> org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(
> > JUnit3TestReference.java:128)
> >     at org.eclipse.jdt.internal.junit.runner.TestExecution.run(
> > TestExecution.java:38)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> > RemoteTestRunner.java:460)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> > RemoteTestRunner.java:673)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(
> > RemoteTestRunner.java:386)
> >     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(
> > RemoteTestRunner.java:196)
> >
> > "VM Thread" prio=1 tid=0x080a0280 nid=0x70a1 runnable
> >
> > "VM Periodic Task Thread" prio=1 tid=0x080ad5d0 nid=0x70a7 waiting on
> > condition
> >
> > Att,
> >
> > Márcio Moraes
> >
> >
> > 2007/9/27, Hiram Chirino <hi...@hiramchirino.com>:
> > >
> > > Howdy folks.
> > >
> > > I've done the first release candidate build of activemq 5.0.0.  You
> can
> > > get the
> > > binary distributions here:
> > >
> > >
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> > > maven 2 repo:
> > > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > > maven 1 repo:
> > > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> > >
> > > Please check out this build and let me know if you see anything out of
> > > place.
> > >
> > > --
> > > Regards,
> > > Hiram
> > >
> > > Blog: http://hiramchirino.com
> > >
> >
>
>
> --
> Regards,
> Hiram
>
> Blog: http://hiramchirino.com
>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

Hi Márcio,

What usage scenario was that?  Queues, Persistent messages, over
tcp:// using a the default broker?  Were you using transactions?


On 9/27/07, Márcio Moraes <mm...@gmail.com> wrote:
> I ran somes testes using kaha as persistence
>
> My test send many messages to a consumer, after ~6000 messages client hangs.
>
> Following is the client stack trace
>
> "ActiveMQ Session Task" daemon prio=1 tid=0x08878a68 nid=0x70af waiting on
> condition [0xafa73000..0xafa73db0]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(
> AbstractQueuedSynchronizer.java:716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(
> AbstractQueuedSynchronizer.java:1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java:400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask(
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Scheduler" daemon prio=1 tid=0x088523e8 nid=0x70ae in Object.wait()
> [0xafaf4000..0xafaf5130]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f57148> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f57148> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
> tid=0x0882df60 nid=0x70ad runnable [0xafb75000..0xafb760b0]
>     at java.net.SocketInputStream.socketRead0(Native Method)
>     at java.net.SocketInputStream.read(SocketInputStream.java:129)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
> TcpBufferedInputStream.java:50)
>     at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
> TcpBufferedInputStream.java:58)
>     at java.io.DataInputStream.readInt(DataInputStream.java:353)
>     at org.apache.activemq.openwire.OpenWireFormat.unmarshal(
> OpenWireFormat.java:268)
>     at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
> TcpTransport.java:196)
>     at org.apache.activemq.transport.tcp.TcpTransport.doRun(
> TcpTransport.java:188)
>     at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java
> :176)
>     at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Task" daemon prio=1 tid=0x0882e500 nid=0x70ac waiting on condition
> [0xafbf6000..0xafbf7030]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(
> AbstractQueuedSynchronizer.java:716)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
> (AbstractQueuedSynchronizer.java:771)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(
> AbstractQueuedSynchronizer.java:1099)
>     at java.util.concurrent.SynchronousQueue$Node.waitForPut(
> SynchronousQueue.java:265)
>     at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java:400)
>     at java.util.concurrent.ThreadPoolExecutor.getTask(
> ThreadPoolExecutor.java:470)
>     at java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:674)
>     at java.lang.Thread.run(Thread.java:595)
>
> "Timer-0" daemon prio=1 tid=0x08812620 nid=0x70ab in Object.wait()
> [0xafc77000..0xafc77fb0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88f31158> (a java.util.TaskQueue)
>     at java.util.TimerThread.mainLoop(Timer.java:509)
>     - locked <0x88f31158> (a java.util.TaskQueue)
>     at java.util.TimerThread.run(Timer.java:462)
>
> "ReaderThread" prio=1 tid=0x0829b5f0 nid=0x70a8 runnable
> [0xafcf8000..0xafcf8f30]
>     at java.net.SocketInputStream.socketRead0(Native Method)
>     at java.net.SocketInputStream.read(SocketInputStream.java:129)
>     at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java:411)
>     at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java:453)
>     at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:183)
>     - locked <0x88ebeca0> (a java.io.InputStreamReader)
>     at java.io.InputStreamReader.read(InputStreamReader.java:167)
>     at java.io.BufferedReader.fill(BufferedReader.java:136)
>     at java.io.BufferedReader.readLine(BufferedReader.java:299)
>     - locked <0x88ebeca0> (a java.io.InputStreamReader)
>     at java.io.BufferedReader.readLine(BufferedReader.java:362)
>     at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner$ReaderThread.run(
> RemoteTestRunner.java:140)
>
> "Low Memory Detector" daemon prio=1 tid=0x080ac0e0 nid=0x70a6 runnable
> [0x00000000..0x00000000]
>
> "CompilerThread0" daemon prio=1 tid=0x080aab30 nid=0x70a5 waiting on
> condition [0x00000000..0xb2265798]
>
> "Signal Dispatcher" daemon prio=1 tid=0x080a9ba8 nid=0x70a4 runnable
> [0x00000000..0x00000000]
>
> "Finalizer" daemon prio=1 tid=0x080a23f8 nid=0x70a3 in Object.wait()
> [0xb23a1000..0xb23a20b0]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
>     - locked <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
>     at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
>     at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)
>
> "Reference Handler" daemon prio=1 tid=0x080a16b8 nid=0x70a2 in Object.wait()
> [0xb2422000..0xb2423030]
>     at java.lang.Object.wait(Native Method)
>     - waiting on <0x88e954b8> (a java.lang.ref.Reference$Lock)
>     at java.lang.Object.wait(Object.java:474)
>     at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
>     - locked <0x88e954b8> (a java.lang.ref.Reference$Lock)
>
> "main" prio=1 tid=0x08061c70 nid=0x709b waiting on condition
> [0xbfd0f000..0xbfd100f8]
>     at sun.misc.Unsafe.park(Native Method)
>     at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
>     at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(
> AbstractQueuedSynchronizer.java:1841)
>     at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java
> :341)
>     at org.apache.activemq.transport.FutureResponse.getResult(
> FutureResponse.java:40)
>     at org.apache.activemq.transport.ResponseCorrelator.request(
> ResponseCorrelator.java:76)
>     at org.apache.activemq.ActiveMQConnection.syncSendPacket(
> ActiveMQConnection.java:1168)
>     at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1635)
>     - locked <0x88f67550> (a java.lang.Object)
>     at org.apache.activemq.ActiveMQMessageProducer.send(
> ActiveMQMessageProducer.java:226)
>     at org.apache.activemq.ActiveMQMessageProducerSupport.send(
> ActiveMQMessageProducerSupport.java:299)
>     at org.apache.activemq.ActiveMQTopicPublisher.publish(
> ActiveMQTopicPublisher.java:171)
>     at org.jencks.amqpool.PooledTopicPublisher.publish(
> PooledTopicPublisher.java:50)
>     at uol.auction.messaging.TopicMessageBroker.request(
> TopicMessageBroker.java:154)
>     at uol.auction.messaging.TopicMessageBroker.request(
> TopicMessageBroker.java:131)
>     at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
> DiagnosticMessageBrokerTest.java:42)
>     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:585)
>     at junit.framework.TestCase.runTest(TestCase.java:154)
>     at junit.framework.TestCase.runBare(TestCase.java:127)
>     at junit.framework.TestResult$1.protect(TestResult.java:106)
>     at junit.framework.TestResult.runProtected(TestResult.java:124)
>     at junit.framework.TestResult.run(TestResult.java:109)
>     at junit.framework.TestCase.run(TestCase.java:118)
>     at junit.framework.TestSuite.runTest(TestSuite.java:208)
>     at junit.framework.TestSuite.run(TestSuite.java:203)
>     at org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(
> JUnit3TestReference.java:128)
>     at org.eclipse.jdt.internal.junit.runner.TestExecution.run(
> TestExecution.java:38)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> RemoteTestRunner.java:460)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
> RemoteTestRunner.java:673)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(
> RemoteTestRunner.java:386)
>     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(
> RemoteTestRunner.java:196)
>
> "VM Thread" prio=1 tid=0x080a0280 nid=0x70a1 runnable
>
> "VM Periodic Task Thread" prio=1 tid=0x080ad5d0 nid=0x70a7 waiting on
> condition
>
> Att,
>
> Márcio Moraes
>
>
> 2007/9/27, Hiram Chirino <hi...@hiramchirino.com>:
> >
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq 5.0.0.  You can
> > get the
> > binary distributions here:
> >
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> > maven 2 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > maven 1 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> >
> > Please check out this build and let me know if you see anything out of
> > place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Márcio Moraes <mm...@gmail.com>.

I ran somes testes using kaha as persistence

My test send many messages to a consumer, after ~6000 messages client hangs.

Following is the client stack trace

"ActiveMQ Session Task" daemon prio=1 tid=0x08878a68 nid=0x70af waiting on
condition [0xafa73000..0xafa73db0]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(
AbstractQueuedSynchronizer.java:716)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
(AbstractQueuedSynchronizer.java:771)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(
AbstractQueuedSynchronizer.java:1099)
    at java.util.concurrent.SynchronousQueue$Node.waitForPut(
SynchronousQueue.java:265)
    at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java:400)
    at java.util.concurrent.ThreadPoolExecutor.getTask(
ThreadPoolExecutor.java:470)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(
ThreadPoolExecutor.java:674)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Scheduler" daemon prio=1 tid=0x088523e8 nid=0x70ae in Object.wait()
[0xafaf4000..0xafaf5130]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88f57148> (a java.util.TaskQueue)
    at java.util.TimerThread.mainLoop(Timer.java:509)
    - locked <0x88f57148> (a java.util.TaskQueue)
    at java.util.TimerThread.run(Timer.java:462)

"ActiveMQ Transport: tcp://topeira2/192.168.67.40:61616" prio=1
tid=0x0882df60 nid=0x70ad runnable [0xafb75000..0xafb760b0]
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.read(SocketInputStream.java:129)
    at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(
TcpBufferedInputStream.java:50)
    at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(
TcpBufferedInputStream.java:58)
    at java.io.DataInputStream.readInt(DataInputStream.java:353)
    at org.apache.activemq.openwire.OpenWireFormat.unmarshal(
OpenWireFormat.java:268)
    at org.apache.activemq.transport.tcp.TcpTransport.readCommand(
TcpTransport.java:196)
    at org.apache.activemq.transport.tcp.TcpTransport.doRun(
TcpTransport.java:188)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java
:176)
    at java.lang.Thread.run(Thread.java:595)

"ActiveMQ Task" daemon prio=1 tid=0x0882e500 nid=0x70ac waiting on condition
[0xafbf6000..0xafbf7030]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(
AbstractQueuedSynchronizer.java:716)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly
(AbstractQueuedSynchronizer.java:771)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(
AbstractQueuedSynchronizer.java:1099)
    at java.util.concurrent.SynchronousQueue$Node.waitForPut(
SynchronousQueue.java:265)
    at java.util.concurrent.SynchronousQueue.take(SynchronousQueue.java:400)
    at java.util.concurrent.ThreadPoolExecutor.getTask(
ThreadPoolExecutor.java:470)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(
ThreadPoolExecutor.java:674)
    at java.lang.Thread.run(Thread.java:595)

"Timer-0" daemon prio=1 tid=0x08812620 nid=0x70ab in Object.wait()
[0xafc77000..0xafc77fb0]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88f31158> (a java.util.TaskQueue)
    at java.util.TimerThread.mainLoop(Timer.java:509)
    - locked <0x88f31158> (a java.util.TaskQueue)
    at java.util.TimerThread.run(Timer.java:462)

"ReaderThread" prio=1 tid=0x0829b5f0 nid=0x70a8 runnable
[0xafcf8000..0xafcf8f30]
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.read(SocketInputStream.java:129)
    at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java:411)
    at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java:453)
    at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:183)
    - locked <0x88ebeca0> (a java.io.InputStreamReader)
    at java.io.InputStreamReader.read(InputStreamReader.java:167)
    at java.io.BufferedReader.fill(BufferedReader.java:136)
    at java.io.BufferedReader.readLine(BufferedReader.java:299)
    - locked <0x88ebeca0> (a java.io.InputStreamReader)
    at java.io.BufferedReader.readLine(BufferedReader.java:362)
    at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner$ReaderThread.run(
RemoteTestRunner.java:140)

"Low Memory Detector" daemon prio=1 tid=0x080ac0e0 nid=0x70a6 runnable
[0x00000000..0x00000000]

"CompilerThread0" daemon prio=1 tid=0x080aab30 nid=0x70a5 waiting on
condition [0x00000000..0xb2265798]

"Signal Dispatcher" daemon prio=1 tid=0x080a9ba8 nid=0x70a4 runnable
[0x00000000..0x00000000]

"Finalizer" daemon prio=1 tid=0x080a23f8 nid=0x70a3 in Object.wait()
[0xb23a1000..0xb23a20b0]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:116)
    - locked <0x88e95438> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:132)
    at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:159)

"Reference Handler" daemon prio=1 tid=0x080a16b8 nid=0x70a2 in Object.wait()
[0xb2422000..0xb2423030]
    at java.lang.Object.wait(Native Method)
    - waiting on <0x88e954b8> (a java.lang.ref.Reference$Lock)
    at java.lang.Object.wait(Object.java:474)
    at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:116)
    - locked <0x88e954b8> (a java.lang.ref.Reference$Lock)

"main" prio=1 tid=0x08061c70 nid=0x709b waiting on condition
[0xbfd0f000..0xbfd100f8]
    at sun.misc.Unsafe.park(Native Method)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
    at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(
AbstractQueuedSynchronizer.java:1841)
    at java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java
:341)
    at org.apache.activemq.transport.FutureResponse.getResult(
FutureResponse.java:40)
    at org.apache.activemq.transport.ResponseCorrelator.request(
ResponseCorrelator.java:76)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(
ActiveMQConnection.java:1168)
    at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1635)
    - locked <0x88f67550> (a java.lang.Object)
    at org.apache.activemq.ActiveMQMessageProducer.send(
ActiveMQMessageProducer.java:226)
    at org.apache.activemq.ActiveMQMessageProducerSupport.send(
ActiveMQMessageProducerSupport.java:299)
    at org.apache.activemq.ActiveMQTopicPublisher.publish(
ActiveMQTopicPublisher.java:171)
    at org.jencks.amqpool.PooledTopicPublisher.publish(
PooledTopicPublisher.java:50)
    at uol.auction.messaging.TopicMessageBroker.request(
TopicMessageBroker.java:154)
    at uol.auction.messaging.TopicMessageBroker.request(
TopicMessageBroker.java:131)
    at uol.auction.domain.business.DiagnosticMessageBrokerTest.test(
DiagnosticMessageBrokerTest.java:42)
    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:585)
    at junit.framework.TestCase.runTest(TestCase.java:154)
    at junit.framework.TestCase.runBare(TestCase.java:127)
    at junit.framework.TestResult$1.protect(TestResult.java:106)
    at junit.framework.TestResult.runProtected(TestResult.java:124)
    at junit.framework.TestResult.run(TestResult.java:109)
    at junit.framework.TestCase.run(TestCase.java:118)
    at junit.framework.TestSuite.runTest(TestSuite.java:208)
    at junit.framework.TestSuite.run(TestSuite.java:203)
    at org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(
JUnit3TestReference.java:128)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(
TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
RemoteTestRunner.java:460)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(
RemoteTestRunner.java:673)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(
RemoteTestRunner.java:386)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(
RemoteTestRunner.java:196)

"VM Thread" prio=1 tid=0x080a0280 nid=0x70a1 runnable

"VM Periodic Task Thread" prio=1 tid=0x080ad5d0 nid=0x70a7 waiting on
condition

Att,

Márcio Moraes


2007/9/27, Hiram Chirino <hi...@hiramchirino.com>:
>
> Howdy folks.
>
> I've done the first release candidate build of activemq 5.0.0.  You can
> get the
> binary distributions here:
>
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
>
> Please check out this build and let me know if you see anything out of
> place.
>
> --
> Regards,
> Hiram
>
> Blog: http://hiramchirino.com
>

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by David Sitsky <si...@nuix.com>.

Hiram Chirino wrote:
> Howdy folks.
> 
> I've done the first release candidate build of activemq 5.0.0.  You can get the
> binary distributions here:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> 
> Please check out this build and let me know if you see anything out of place.
> 

Hi Hiram,

I still get the error reported at the end of 
https://issues.apache.org/activemq/browse/AMQ-1251, where the following 
is occurring:

[ActiveMQ Task] 881755 ERROR 
org.apache.activemq.broker.region.Queue.worker-items - Failed to page in 
more queue messages
java.lang.RuntimeException: not implemented
at 
org.apache.activemq.broker.region.NullMessageReference.isDropped(NullMessageReference.java:47)
at 
org.apache.activemq.broker.region.cursors.VMPendingMessageCursor.isEmpty(VMPendingMessageCursor.java:43)
at 
org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:119)
at 
org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy.dispatch(RoundRobinDispatchPolicy.java:70)
at org.apache.activemq.broker.region.Queue.doDispatch(Queue.java:1054)
at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1069)
at org.apache.activemq.broker.region.Queue.iterate(Queue.java:940)
at 
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118)
at 
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)

At the moment I made it return false, but what should be done here?

Cheers,
David

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

I had made a small change to a mojo so that it supports disabling the
generation of the spring.handler and spring.schemas files.  That's the
thing we are dependent on for the new version.

On 9/28/07, Guillaume Nodet <gn...@gmail.com> wrote:
> Hmm :-(
> I haven't touched xbean since a few months.  I need to check what are
> the changes there.
>
> On 9/28/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> > I guess we need to release camel and xbean first then.  Guillaume...
> > could you see if you can push the xbean release along?
> >
> > On 9/28/07, Guillaume Nodet <gn...@gmail.com> wrote:
> > > Both xbean and camel versions are snapshots.
> > > We absolutely need to fix that before releasing 5.0.
> > >
> > > On 9/27/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> > > > Howdy folks.
> > > >
> > > > I've done the first release candidate build of activemq 5.0.0.  You can get the
> > > > binary distributions here:
> > > > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> > > > maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > > > maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> > > >
> > > > Please check out this build and let me know if you see anything out of place.
> > > >
> > > > --
> > > > Regards,
> > > > Hiram
> > > >
> > > > Blog: http://hiramchirino.com
> > > >
> > >
> > >
> > > --
> > > Cheers,
> > > Guillaume Nodet
> > > ------------------------
> > > Blog: http://gnodet.blogspot.com/
> > >
> >
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>
>
> --
> Cheers,
> Guillaume Nodet
> ------------------------
> Blog: http://gnodet.blogspot.com/
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Guillaume Nodet <gn...@gmail.com>.

Hmm :-(
I haven't touched xbean since a few months.  I need to check what are
the changes there.

On 9/28/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> I guess we need to release camel and xbean first then.  Guillaume...
> could you see if you can push the xbean release along?
>
> On 9/28/07, Guillaume Nodet <gn...@gmail.com> wrote:
> > Both xbean and camel versions are snapshots.
> > We absolutely need to fix that before releasing 5.0.
> >
> > On 9/27/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> > > Howdy folks.
> > >
> > > I've done the first release candidate build of activemq 5.0.0.  You can get the
> > > binary distributions here:
> > > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> > > maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > > maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> > >
> > > Please check out this build and let me know if you see anything out of place.
> > >
> > > --
> > > Regards,
> > > Hiram
> > >
> > > Blog: http://hiramchirino.com
> > >
> >
> >
> > --
> > Cheers,
> > Guillaume Nodet
> > ------------------------
> > Blog: http://gnodet.blogspot.com/
> >
>
>
> --
> Regards,
> Hiram
>
> Blog: http://hiramchirino.com
>


-- 
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

I guess we need to release camel and xbean first then.  Guillaume...
could you see if you can push the xbean release along?

On 9/28/07, Guillaume Nodet <gn...@gmail.com> wrote:
> Both xbean and camel versions are snapshots.
> We absolutely need to fix that before releasing 5.0.
>
> On 9/27/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq 5.0.0.  You can get the
> > binary distributions here:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> > maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> >
> > Please check out this build and let me know if you see anything out of place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>
>
> --
> Cheers,
> Guillaume Nodet
> ------------------------
> Blog: http://gnodet.blogspot.com/
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Guillaume Nodet <gn...@gmail.com>.

Both xbean and camel versions are snapshots.
We absolutely need to fix that before releasing 5.0.

On 9/27/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> Howdy folks.
>
> I've done the first release candidate build of activemq 5.0.0.  You can get the
> binary distributions here:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
>
> Please check out this build and let me know if you see anything out of place.
>
> --
> Regards,
> Hiram
>
> Blog: http://hiramchirino.com
>


-- 
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

Oh the tag for source of that RC1 build is here:
https://svn.apache.org/repos/asf/activemq/tags/activemq-5.0.0/

On 9/27/07, Hiram Chirino <hi...@hiramchirino.com> wrote:
> Howdy folks.
>
> I've done the first release candidate build of activemq 5.0.0.  You can get the
> binary distributions here:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo: http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
>
> Please check out this build and let me know if you see anything out of place.
>
> --
> Regards,
> Hiram
>
> Blog: http://hiramchirino.com
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

I just committed a change that fixes this..  Please check again once
we put out an RC2.

On 10/1/07, PieterN <se...@internethoofdkantoor.nl> wrote:
>
>
> Hiram Chirino wrote:
> >
> > I've done the first release candidate build of activemq 5.0.0.
> >
> > [snip]
> >
> I still experience this issue:
> https://issues.apache.org/activemq/browse/AMQ-1389 where persistent messages
> get sent again to durable subscribers. I consider this a major blocker.
> Otherwise I've experienced no problems with the RC, other than STOMP
> authentication which still doesn't work (I believe this is targeted for the
> 5.2.0 release?)
>
> Regards,
>
> Pieter
> --
> View this message in context: http://www.nabble.com/Please-help-check-ActiveMQ-5.0.0-RC1-tf4530231s2354.html#a12976690
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by PieterN <se...@internethoofdkantoor.nl>.


Hiram Chirino wrote:
> 
> I've done the first release candidate build of activemq 5.0.0. 
> 
> [snip]
> 
I still experience this issue:
https://issues.apache.org/activemq/browse/AMQ-1389 where persistent messages
get sent again to durable subscribers. I consider this a major blocker.
Otherwise I've experienced no problems with the RC, other than STOMP
authentication which still doesn't work (I believe this is targeted for the
5.2.0 release?)

Regards,

Pieter
-- 
View this message in context: http://www.nabble.com/Please-help-check-ActiveMQ-5.0.0-RC1-tf4530231s2354.html#a12976690
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

Hi Klute,

Could you update those test cases so that they have the apache license
header on them?  That way we can include them as a contribution to the
project.

Thanks!

On 9/28/07, Klute R., ITSC Bonn, RTB, D <Ra...@dp-itsolutions.de> wrote:
> AMQ-1095 is still unfixed. It has a priority of "major" - and rightly so. Several weeks ago I provided a patch and I'd appreciate it (or a better solution) to be integrated into ActiveMQ 5. I consider this a blocker for a 5.0.0 release.
>
> Mit freundlichen Grüßen / Best regards
>
> Rainer Klute
> Architecture & Technology Consulting
>
> IT Services Europe
> Deutsche Post IT Services GmbH
> Konrad-Adenauer-Platz 1
> 40210 Düsseldorf
> Germany
>
> Phone:  +49 (0)211 163 1156
> Mobile: +49 (0)172 2324824
> http://www.dpwn.de/
> rainer.klute@dp-itsolutions.de
>
> OpenPGP fingerprint: 10F3E02A46E48B5BE7F1B70263F50FB920B926C2
>
> > -----Original Message-----
> > From: chirino@gmail.com [mailto:chirino@gmail.com] On Behalf
> > Of Hiram Chirino
> > Sent: Thursday, September 27, 2007 8:36 PM
> > To: dev@activemq.apache.org
> > Subject: Please help check ActiveMQ 5.0.0 RC1
> >
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq
> > 5.0.0.  You can get the binary distributions here:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/ma
> > ven2/org/apache/activemq/apache-activemq/5.0.0/
> > maven 2 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > maven 1 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> >
> > Please check out this build and let me know if you see
> > anything out of place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Please help check ActiveMQ 5.0.0 RC1

Posted by Hiram Chirino <hi...@hiramchirino.com>.

I just applied that fix for this.  Should make it into RC2

On 9/28/07, Klute R., ITSC Bonn, RTB, D <Ra...@dp-itsolutions.de> wrote:
> AMQ-1095 is still unfixed. It has a priority of "major" - and rightly so. Several weeks ago I provided a patch and I'd appreciate it (or a better solution) to be integrated into ActiveMQ 5. I consider this a blocker for a 5.0.0 release.
>
> Mit freundlichen Grüßen / Best regards
>
> Rainer Klute
> Architecture & Technology Consulting
>
> IT Services Europe
> Deutsche Post IT Services GmbH
> Konrad-Adenauer-Platz 1
> 40210 Düsseldorf
> Germany
>
> Phone:  +49 (0)211 163 1156
> Mobile: +49 (0)172 2324824
> http://www.dpwn.de/
> rainer.klute@dp-itsolutions.de
>
> OpenPGP fingerprint: 10F3E02A46E48B5BE7F1B70263F50FB920B926C2
>
> > -----Original Message-----
> > From: chirino@gmail.com [mailto:chirino@gmail.com] On Behalf
> > Of Hiram Chirino
> > Sent: Thursday, September 27, 2007 8:36 PM
> > To: dev@activemq.apache.org
> > Subject: Please help check ActiveMQ 5.0.0 RC1
> >
> > Howdy folks.
> >
> > I've done the first release candidate build of activemq
> > 5.0.0.  You can get the binary distributions here:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/ma
> > ven2/org/apache/activemq/apache-activemq/5.0.0/
> > maven 2 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> > maven 1 repo:
> > http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> >
> > Please check out this build and let me know if you see
> > anything out of place.
> >
> > --
> > Regards,
> > Hiram
> >
> > Blog: http://hiramchirino.com
> >
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

RE: Please help check ActiveMQ 5.0.0 RC1

Posted by "Klute R., ITSC Bonn, RTB, D" <Ra...@dp-itsolutions.de>.

AMQ-1095 is still unfixed. It has a priority of "major" - and rightly so. Several weeks ago I provided a patch and I'd appreciate it (or a better solution) to be integrated into ActiveMQ 5. I consider this a blocker for a 5.0.0 release.

Mit freundlichen Grüßen / Best regards 

Rainer Klute
Architecture & Technology Consulting

IT Services Europe
Deutsche Post IT Services GmbH
Konrad-Adenauer-Platz 1
40210 Düsseldorf
Germany

Phone:  +49 (0)211 163 1156
Mobile: +49 (0)172 2324824
http://www.dpwn.de/
rainer.klute@dp-itsolutions.de

OpenPGP fingerprint: 10F3E02A46E48B5BE7F1B70263F50FB920B926C2 

> -----Original Message-----
> From: chirino@gmail.com [mailto:chirino@gmail.com] On Behalf 
> Of Hiram Chirino
> Sent: Thursday, September 27, 2007 8:36 PM
> To: dev@activemq.apache.org
> Subject: Please help check ActiveMQ 5.0.0 RC1
> 
> Howdy folks.
> 
> I've done the first release candidate build of activemq 
> 5.0.0.  You can get the binary distributions here:
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/ma
> ven2/org/apache/activemq/apache-activemq/5.0.0/
> maven 2 repo: 
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven2
> maven 1 repo: 
> http://people.apache.org/~chirino/apache-activemq-5.0.0-RC1/maven1
> 
> Please check out this build and let me know if you see 
> anything out of place.
> 
> --
> Regards,
> Hiram
> 
> Blog: http://hiramchirino.com
>