0 Replies Latest reply on Mar 14, 2016 9:06 AM by Sreekanth Munarai

    Active MQ-JBoss 5 integration

    Sreekanth Munarai Master

      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