You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by watcher <pa...@daly.ws> on 2010/09/27 21:59:38 UTC
statisticsBrokerPlugin error
Hi
Activemq 5.4
I configured the default activemq.xml conf to use the
statisticsBrokerPlugin
<plugins>
<statisticsBrokerPlugin/>
</plugins>
and added
<import resource="camel.xml"/>
my camel file looks like this.
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<!-- You can use Spring XML syntax to define the routes here using
the <route> element -->
<route>
<from uri="timer://foo?fixedRate=true&period=2000"/>
<inOut
uri="activemq:queue:ActiveMQ.Statistics.Destinationcontest:adj"/>
<to uri="activemq:topic:Statistics.Topic"/>
</route>
</camelContext>
<!--
Lets configure some Camel endpoints
http://camel.apache.org/components.html
-->
<!-- configure the camel activemq component to use the current broker
-->
<bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent" >
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="vm://localhost?create=false&waitForStart=10000" />
<!--
<property name="userName" value="${activemq.username}"/>
<property name="password" value="${activemq.password}"/>
-->
</bean>
</property>
</bean>
However I'm getting errors on startup.
I have a message listener that receives a MapMessage every 20 secs but i
would expect a message every 2secs.
Im i doing somthing wrong.
Please advise.
| jvm 1 | 2010/09/27 20:03:37 | INFO | Transport failed:
org.apache.activemq.transport.TransportDisposedIOException: Peer
(vm://localhost#3) disposed.
INFO | jvm 1 | 2010/09/27 20:03:37 |
org.apache.activemq.transport.TransportDisposedIOException: Peer
(vm://localhost#3) disposed.
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:159)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.vm.VMTransportServer$1.stop(VMTransportServer.java:81)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.util.ServiceSupport.dispose(ServiceSupport.java:43)
INFO | jvm 1 | 2010/09/27 20:03:
INFO | jvm 1 | 2010/09/27 20:03:57 | ERROR | Failed delivery for
exchangeId: abd3623c-9413-4218-b2f9-572760bc8ae7. Exhausted after delivery
attempt: 1 caught: org.apache.camel.ExchangeTimedOutException: The OUT
message was not received within: 20000 millis. Exchange[JmsMessage:
ActiveMQMapMessage {commandId = 0, responseRequired = false, messageId =
ID:LTP1-MYPC-49414-1285614215778-3:0:0:0:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:LTP1-MYPC-49414-1285614215778-3:0:0:0, destination =
temp-queue://ID:LTP1-MYPC-49414-1285614215778-4:0:1, transactionId = null,
expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1285614217035,
brokerOutTime = 1285614217042, correlationId =
157b5bf2-4ce2-4076-8eb3-52664c9743ab, replyTo = null, persistent = false,
type = Advisory, priority = 0, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@dff0ea, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 1024, properties = null,
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQMapMessage{ theTable = {memoryUsage=0, dequeueCount=0,
inflightCount=0, messagesCached=0, averageEnqueueTime=0.0,
destinationName=queue://contest:adj, size=0, memoryPercentUsage=0,
producerCount=0, consumerCount=0, minEnqueueTime=0.0, maxEnqueueTime=0.0,
dispatchCount=0, expiredCount=0, enqueueCount=0, memoryLimit=1048576} }]
INFO | jvm 1 | 2010/09/27 20:03:57 |
org.apache.camel.ExchangeTimedOutException: The OUT message was not received
within: 20000 millis. Exchange[JmsMessage: ActiveMQMapMessage {commandId =
0, responseRequired = false, messageId =
ID:LTP1-MYPC-49414-1285614215778-3:0:0:0:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:LTP1-MYPC-49414-1285614215778-3:0:0:0, destination =
temp-queue://ID:LTP1-MYPC-49414-1285614215778-4:0:1, transactionId = null,
expiration = 0, timestamp = 0, arrival = 0, brokerInTime = 1285614217035,
brokerOutTime = 1285614217042, correlationId =
157b5bf2-4ce2-4076-8eb3-52664c9743ab, replyTo = null, persistent = false,
type = Advisory, priority = 0, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@dff0ea, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 1024, properties = null,
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQMapMessage{ theTable = {memoryUsage=0, dequeueCount=0,
inflightCount=0, messagesCached=0, averageEnqueueTime=0.0,
destinationName=queue://contest:adj, size=0, memoryPercentUsage=0,
producerCount=0, consumerCount=0, minEnqueueTime=0.0, maxEnqueueTime=0.0,
dispatchCount=0, expiredCount=0, enqueueCount=0, memoryLimit=1048576} }]
INFO | jvm 1 | 2010/09/27 20:03:57 | at
org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265)
INFO | jvm 1 | 2010/09/27 20:03:57 | at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147)
INFO | jvm 1 | 2010/09/27 20:03:57 | at
org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)
--
View this message in context: http://activemq.2283324.n4.nabble.com/statisticsBrokerPlugin-error-tp2716123p2716123.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: statisticsBrokerPlugin error
Posted by watcher <pa...@daly.ws>.
Thanks Gary for the reply
I kinda figured it wasnt to important after seeing the INFO log level.
What worries me is the fact that I needed to modify the route as explained
in the ActiveMq in Action book.
Makes me think I'm doing something wrong.
also according to
http://activemq.apache.org/statisticsplugin.html
http://activemq.apache.org/statisticsplugin.html
It suggests I can specify a wildcard as shown previously and a seperate
message will be sent to each route.
Not sure if it is a camel issue or activemq problem.
I might try implementing it as explained in the link above to make sure.
Regards
--
View this message in context: http://activemq.2283324.n4.nabble.com/statisticsBrokerPlugin-error-tp2716123p2965686.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: statisticsBrokerPlugin error
Posted by Gary Tully <ga...@gmail.com>.
The INFO message about vm transport disposed, they can be ignored,
there was an issue for that that has been resolve on trunk:
https://issues.apache.org/activemq/browse/AMQ-2902
On 29 September 2010 21:18, watcher <pa...@daly.ws> wrote:
>
> I solved the timeout issue by setting the pattern to InOnly so Camel will
> send the message and not expect a reply.
>
> <route>
> <from uri="timer://foo?fixedRate=true&period=2000"/>
> <inOut
> uri="activemq:queue:ActiveMQ.Statistics.Destinationcontest:adj"/>
> <to uri="activemq:topic:Statistics.Topic" pattern="InOnly"/>
> </route>
>
> However I can still see many of the following exceptions been thrown in
> wrapper.log
>
> Should I ignore them?
>
> | jvm 1 | 2010/09/27 20:03:37 | INFO | Transport failed:
> org.apache.activemq.transport.TransportDisposedIOException: Peer
> (vm://localhost#3) disposed.
> INFO | jvm 1 | 2010/09/27 20:03:37 |
> org.apache.activemq.transport.TransportDisposedIOException: Peer
> (vm://localhost#3) disposed.
> INFO | jvm 1 | 2010/09/27 20:03:37 | at
> org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:159)
> INFO | jvm 1 | 2010/09/27 20:03:37 | at
> org.apache.activemq.transport.vm.VMTransportServer$1.stop(VMTransportServer.java:81)
> INFO | jvm 1 | 2010/09/27 20:03:37 | at
> org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
> INFO | jvm 1 | 2010/09/27 20:03:37 | at
> org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
> INFO | jvm 1 | 2010/09/27 20:03:37 | at
> org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)
> INFO | jvm 1 | 2010/09/27 20:03:37 | at
> org.apache.activemq.util.ServiceSupport.dispose(ServiceSupport.java:43)
> INFO | jvm 1 | 2010/09/27 20:03:
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/statisticsBrokerPlugin-error-tp2716123p2719707.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
Re: statisticsBrokerPlugin error
Posted by watcher <pa...@daly.ws>.
I've noticed another issue here.
I'm now trying to use a wildcard to get stats from multiple queues.
I have 2 or more queues, for example
contest:adj.1
contest:adj.2
....
contest:adj.N
here's my route
<route>
<from uri="timer://foo?fixedRate=true&period=2000"/>
<inOut
uri="activemq:queue:ActiveMQ.Statistics.Destinationcontest:adj.*"/>
<to uri="activemq:topic:Statistics.Topic" pattern="InOnly"/>
</route>
But in my consumer I only every receive stats for one queue.
I've tested with the following and my consumer will receive both stats.
<route>
<from uri="timer://foo?fixedRate=true&period=2000"/>
<inOut
uri="activemq:queue:ActiveMQ.Statistics.Destinationcontest:adj.1"/>
<to uri="activemq:topic:Statistics.Topic" pattern="InOnly"/>
</route>
<route>
<from uri="timer://foo1?fixedRate=true&period=2000"/>
<inOut
uri="activemq:queue:ActiveMQ.Statistics.Destinationcontest:adj.2"/>
<to uri="activemq:topic:Statistics.Topic" pattern="InOnly"/>
</route>
Any ideas?
Thanks
--
View this message in context: http://activemq.2283324.n4.nabble.com/statisticsBrokerPlugin-error-tp2716123p2956800.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: statisticsBrokerPlugin error
Posted by watcher <pa...@daly.ws>.
I solved the timeout issue by setting the pattern to InOnly so Camel will
send the message and not expect a reply.
<route>
<from uri="timer://foo?fixedRate=true&period=2000"/>
<inOut
uri="activemq:queue:ActiveMQ.Statistics.Destinationcontest:adj"/>
<to uri="activemq:topic:Statistics.Topic" pattern="InOnly"/>
</route>
However I can still see many of the following exceptions been thrown in
wrapper.log
Should I ignore them?
| jvm 1 | 2010/09/27 20:03:37 | INFO | Transport failed:
org.apache.activemq.transport.TransportDisposedIOException: Peer
(vm://localhost#3) disposed.
INFO | jvm 1 | 2010/09/27 20:03:37 |
org.apache.activemq.transport.TransportDisposedIOException: Peer
(vm://localhost#3) disposed.
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:159)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.vm.VMTransportServer$1.stop(VMTransportServer.java:81)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)
INFO | jvm 1 | 2010/09/27 20:03:37 | at
org.apache.activemq.util.ServiceSupport.dispose(ServiceSupport.java:43)
INFO | jvm 1 | 2010/09/27 20:03:
--
View this message in context: http://activemq.2283324.n4.nabble.com/statisticsBrokerPlugin-error-tp2716123p2719707.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.