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.byteseque...@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.byteseque...@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.
