Active MQ-JBoss 5 integration
Hi All,
I'm very keen to know about the functionality and benefits of using Active-MQ. I started out working on the same referring Apache ActiveMQ ™ -- JBoss Integration.
Everything went normal. After adding activemq-jms-ds.xml in deploy directory of JBoss, getting below error while starting the server:
17:44:16,379 ERROR [AbstractKernelController] Error installing to Real: name=vfsfile:/D:/Sreekanth/MQ-JBoss/jboss-5.1.0.GA/server/default/deploy/activemq-jms-ds.xml state=PreReal mode=Manual requiredState=Real
org.jboss.deployers.spi.DeploymentException: Error during deploy: vfsfile:/D:/Sreekanth/MQ-JBoss/jboss-5.1.0.GA/server/default/deploy/activemq-jms-ds.xml
at org.jboss.deployers.spi.DeploymentException.rethrowAsDeploymentException(DeploymentException.java:49)
at org.jboss.deployers.plugins.deployers.DeployerWrapper.deploy(DeployerWrapper.java:177)
at org.jboss.deployers.plugins.deployers.DeployersImpl.doDeploy(DeployersImpl.java:1439)
at org.jboss.deployers.plugins.deployers.DeployersImpl.doInstallParentFirst(DeployersImpl.java:1157)
at org.jboss.deployers.plugins.deployers.DeployersImpl.install(DeployersImpl.java:1098)
at org.jboss.dependency.plugins.AbstractControllerContext.install(AbstractControllerContext.java:348)
at org.jboss.dependency.plugins.AbstractController.install(AbstractController.java:1631)
at org.jboss.dependency.plugins.AbstractController.incrementState(AbstractController.java:934)
............
Caused by: java.lang.IllegalStateException: No ConnectorMetaData found for mdf rarName: activemq-ra.rar
at org.jboss.resource.deployers.builder.ManagedConnectionFactoryBuilder.buildConstructor(ManagedConnectionFactoryBuilder.java:83)
at org.jboss.resource.deployers.builder.AbstractBuilder.buildService(AbstractBuilder.java:56)
at org.jboss.resource.deployers.builder.AbstractBuilder.build(AbstractBuilder.java:65)
...........
However, the server was started an was able to access the console./
Then as i mentioned in the above referral link, have started two terminals/cmd. One is for ant consumer and other one is ant producer.
terminal/ant consumer:
[java] Received: Message: 1989 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1990 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1991 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1992 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1993 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1994 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1995 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1996 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1997 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1998 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Received: Message: 1999 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Closing connection
[java] Picked up _JAVA_OPTIONS: -Xmx1024m
BUILD SUCCESSFUL
Total time: 2 minutes 30 seconds
terminal/ant producer:
[java] Sending message: Message: 1996 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Sending message: Message: 1997 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Sending message: Message: 1998 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Sending message: Message: 1999 sent at: Mon Mar 14 18:15:18 IST 201...
[java] Done.
[java] connection {
[java] session {
[java] messageCount{ count: 0 unit: count startTime: 1457959491847 lastSampleTime: 1457959491847 description: Number of messages exchanged }
[java] messageRateTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1457959491847 lastSampleTime: 1457959491847 description: Time taken to process a message (thoughtput rate
) }
[java] pendingMessageCount{ count: 0 unit: count startTime: 1457959491847 lastSampleTime: 1457959491847 description: Number of pending messages }
[java] expiredMessageCount{ count: 0 unit: count startTime: 1457959491847 lastSampleTime: 1457959491847 description: Number of expired messages }
[java] messageWaitTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1457959491847 lastSampleTime: 1457959491847 description: Time spent by a message before being delivered }
[java] durableSubscriptionCount{ count: 0 unit: count startTime: 1457959491847 lastSampleTime: 1457959491847 description: The number of durable subscriptions }
[java]
[java] producers {
[java] producer queue://TEST.FOO {
[java] messageCount{ count: 0 unit: count startTime: 1457959492050 lastSampleTime: 1457959492050 description: Number of messages processed }
[java] messageRateTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1457959492050 lastSampleTime: 1457959492050 description: Time taken to process a message (thoughtput
rate) }
[java] pendingMessageCount{ count: 0 unit: count startTime: 1457959492050 lastSampleTime: 1457959492050 description: Number of pending messages }
[java] messageRateTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1457959492050 lastSampleTime: 1457959492050 description: Time taken to process a message (thoughtput
rate) }
[java] expiredMessageCount{ count: 0 unit: count startTime: 1457959492050 lastSampleTime: 1457959492050 description: Number of expired messages }
[java] messageWaitTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0 averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0 averagePerSecondExMinMax: 0.0 unit: millis startTime: 1457959492050 lastSampleTime: 1457959492050 description: Time spent by a message before being deliver
ed }
[java] }
[java] }
[java] consumers {
[java] }
[java] }
[java] }
[java] Picked up _JAVA_OPTIONS: -Xmx1024m
BUILD SUCCESSFUL
Is everything normal as expected? if yes, is there any more ways to test MQ with more real examples,please advise.
Please suggest to understand more about this product.
Thanks,
Sreekanth