I am quite OK with the build-in JMS in Glassfish (OpenMQ), as long you dont want to access queues from external applications or you need an admin console to easily create, delete queues, send messages and browse the queues. ActiveMQ is a good alternative. Unfortunately we could not find any end2end description hot to get the couple Glassfish-ActiveMQ up and running (under Linux, Windows should be a quite similar affair).
This tutorial describes how to install and configure ActiveMQ as embedded JMS broker, and connect a MDB to it.
Pre-Requirements:
- Running Glassfish 3.1 instance (or later).
Tutorial
- Download the current ActiveMQ package
At the time of writing it is 5.5.0 (apache-activemq-5.5.0-bin.tar.gz)
apache-activemq-5.5.0-bin.tar.gz
- Add libraries to the Glassfish lib folder (GLASSFISH_HOME/glassfish/lib)
All files you find in the ActiveMQ package- activemq-all-5.5.0.jar
- slf4j-api-1.5.11.jar
- log4j-1.2.14.jar
- slf4j-log4j12-1.5.11.jar
Optional: Replace the log4j jars with logback logging (here the current versions)
- slf4j-api-1.6.1.jar
- logback-core-0.9.29.jar
- logback-classic-0.9.29.jar
- Download the separate resource adapter (link)
We could not make the generic resource adapter work (http://genericjmsra.java.net/)
(No longer included in the ActiveMQ package)- activemq-ra-5.5.0.jar
- activemq-rar-5.5.0.rar
- Place the resource adapter jar file in the Glassfish lib folder (GLASSFISH_HOME/glassfish/lib)
Restart Glassfish if it is running. - Deploy the resource adapter
activemq-rar-5.5.0.rar
Resource Adapter
Resource Adapter
- Create Resource Adapter Configuration
Select a threadpool and change these settings- ServerUrl: vm://localhost:61616
- BrokerXmlConfig: broker:(tcp://localhost:61616)
Update 2011-08-02: Use 0.0.0.0 instead of localhost, otherwise you will get a Connection Refused error from external clients (from a different host)
Resource Adapter Configuration
- Add Connector Connection Pool ‘amqpool’
Second page with default settings
Connector Connection Pool
Connector Connection Pool
- Add new Connector Resource ‘amqres’
with previous pool ‘amqpool’
Connector Resource
- Add Admin Object Resource‘amqmsg’
Admin Object Resource
- Add JVM Settings
- -Dwebconsole.type=properties
- -Dwebconsole.jms.url=tcp://localhost:61616
- -Dwebconsole.jmx.url=service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
and restart Glassfish
JVM Settings
- Download and deploy the ActiveMQ Console Web App (link)
activemq-web-console-5.5.0.war
ActiveMQ Console
- Run the admin Console(http://localhost:8080/activemq-web-console-5.5.)
ActiveMQ Admin Console
- Create a queue with the same name as Admin Object Resource‘amqmsg’
New Queue
Right now we already have a fully working ActiveMQ ‘inside’ our Glassfish. In Part 2 we create a simple Java SE app to write to the queue, in Part 3 we will create a MDB (message driven bean) to listen to the queue.
Remarks:
- Please note all above settings are made out-of-the-box. It is up to you to secure the instance with user-id’s and passwords, eventually change ports and so on.
- Starting up Glassfish should show a log like this
INFO: 2011-07-21 15:15:41,482 [ActiveMQ Broker] INFO PListStore - PListStore:activemq-data/localhost/tmp_storage started INFO: 2011-07-21 15:15:41,486 [ActiveMQ Broker] INFO BrokerService - Using Persistence Adapter: KahaDBPersistenceAdapter[/home/user/glassfish-3.1/glassfish/domains/domain1/activemq-data/localhost/KahaDB] INFO: 2011-07-21 15:15:42,379 [ActiveMQ Broker] INFO MessageDatabase - KahaDB is version 3 INFO: 2011-07-21 15:15:42,399 [ActiveMQ Broker] INFO MessageDatabase - Recovering from the journal ... INFO: 2011-07-21 15:15:42,399 [ActiveMQ Broker] INFO MessageDatabase - Recovery replayed 1 operations from the journal in 0.011 seconds. INFO: 2011-07-21 15:15:42,409 [ActiveMQ Broker] INFO BrokerService - ActiveMQ 5.5.0 JMS Message Broker (localhost) is starting INFO: 2011-07-21 15:15:42,409 [ActiveMQ Broker] INFO BrokerService - For help or more information please see: http://activemq.apache.org/ INFO: 2011-07-21 15:15:42,946 [ActiveMQ Broker] INFO TransportServerThreadSupport - Listening for connections at: tcp://localhost.localdomain:61616 INFO: 2011-07-21 15:15:42,947 [ActiveMQ Broker] INFO TransportConnector - Connector tcp://localhost.localdomain:61616 Started INFO: 2011-07-21 15:15:42,949 [ActiveMQ Broker] INFO BrokerService - ActiveMQ JMS Message Broker (localhost, ID:GISBORNE-55741-1311232542431-0:1) started
- There is a little display problem under JMS resources. The ActiveMQ resources are not displayed in the list, but on the left side.
References:
- Thanks to Alphy for digging out a lot of above details.
- Manning: ActiveMQ in Action (http://www.manning.com/snyder/)
- ActiveMQ Documentation (http://activemq.apache.org/using-activemq-5.html)
- and dozens of forum threads all over the web.
The JavaDude Weblog 
Pingback: Tutorial: Starting with Glassfish and JMS « The JavaDude Weblog
Hie i managed to setup activemq in glassfish
however i get the following error
INFO: Exception Occurred :java.lang.RuntimeException: REST Request ‘http://localhost:4848/management/domain/resources/connector-resource/amqpool’ failed with response code ‘404’.
At what step does this happen ?
I believe there is also a bug in GF admin console. More on that later.
try to give pool name and jndiname as same.amqpool instead of amqres.
Thanks for the help
the resource and connection factory now seems ok
i can send and receive messages from a java se client
however my MDB can seem to pick up the messages
i created a test queue name jms/testQueue
and find attached my MDB code :
@MessageDriven(mappedName = “jms/testQueue”, activationConfig = {
@ActivationConfigProperty(propertyName = “acknowledgeMode”, propertyValue = “Auto-acknowledge”),
@ActivationConfigProperty(propertyName = “destinationType”, propertyValue = “javax.jms.Queue”)
})
public class TestMDB implements MessageListener {
public TestMDB() {
}
@Override
public void onMessage(Message message) {
if(message instanceof TextMessage){
try {
TextMessage message1 = (TextMessage)message;
System.out.println(“########## ” + message1.getText());
} catch (JMSException ex) {
Logger.getLogger(TestMDB.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}
i get the following in my log as well :
INFO: RAR8029: Resource [ jms/testQueue ] of type [ aor ] is not enabled
INFO: RAR8029: Resource [ jms/testQueue ] of type [ aor ] is not enabled
Pingback: Glassfish V3.1 running embedded ActiveMQ for JMS (Part 3) « The JavaDude Weblog
RAR8029: Resource [ jms/testQueue ] of type [ aor ] is not enabled
I also got this once. Did u restart glassfish after change.Also check in domain.xml whether enabled=false for this resource.if false,change to true and restart.
great paper,it’s work fine.
I have a question,how to add STOMP broker for other language such as PHP ?
Hi,
I am using Glassfish 3.1.1. I am able to deploy activemq-rar-5.5.0 application successfully and create Msg Resources. However I am not able to deploy activemq-web-console-5.5.0.war. I get the error: WebConsoleStarter is not found.
I have tried many option, like building active-web-console-5.5.0 by downloading source code. Nothing has worked. Can you please guide me.
Pingback: Integracja ActiveMQ 5.x z Glassfish 3.1 « Zapiski programisty
Pingback: Jms | TagHall
Pingback: How to connect Glassfish 3 to an external ActiveMQ 5 broker « Geert Schuring
Thanks for the info Sven!
I’ve written an article based on yours about connecting glassfish to an external activemq broker: http://geertschuring.wordpress.com/2012/04/20/how-to-connect-glassfish-3-to-activemq-5/
Kind regards,
Geert Schuring.
Hi, nice post. A colleague used it word for word to set up our activeMQ instance in Glassfish3 with great success. However, he’s also java dude whereas I’m not, so we’ve still got a problem – I’d like to be able to connect to it via STOMP.
I’ve done exactly that just fine with activeMq running in isolation by just adding the following lines to activemq.xml:
(as per http://activemq.apache.org/stomp.html)
As the glassfish deployment doesn’t take across the activemq.xml file from the source, do you have any idea where we could add this to enable STOMP?
It’s probably super simple, I just can’t figure it out.
Thanks very much!
For anyone else that has this question – I had the same problem except for MQTT, what you do is add the extra broker to the end of the first in the BrokerXmlConfig properties in “Resource Adapter Config”… mine looks like this:
broker:(tcp://0.0.0.0:61616,mqtt://0.0.0.0:7771)
You will then need to add any required jars out of the ActiveMQ zip file to the lib folder where you put everything else above, restart GlassFish and it should work. This page kind of shows the format:
http://activemq.apache.org/run-broker.html
According to the ActiveMQ page on stomp ( http://activemq.apache.org/stomp.html ) – the broker would look like this:
broker:(tcp://0.0.0.0:61616,stomp://localhost:61613)
PS – I realise that’s asking quite a lot given the amazing detail of the post itself, but you seem like a bit of an expert on the activemq-glassfish subject! Thanks!
Pingback: Glassfish V3.1 running embedded ActiveMQ for JMS (Updates) | The JavaDude Weblog
Exactly how long did it take u to compose “Glassfish V3.
1 running embedded ActiveMQ for JMS (Part 1) | The JavaDude Weblog”?
It comes with plenty of excellent details. Thanks a lot ,Angelica
Screenshots and typing maybe around 2 hrs. Write frequently than you will be faster.
I am trying to integrate Active MQ with Glassfish Server.
I am following this link.
I get below error
C:\glassfish\glassfishv3\glassfish\bin>asadmin deploy c:/temp/activemq-web-conso le-5.8.0.war
com.sun.enterprise.admin.cli.CommandException: remote failure: There is no insta lled container capable of handling this application com.sun.enterprise.deploy.sh ared.FileArchive@118b940
Is there any solution to this problem?
Did you install the resource adapter first ?
Did you put all required lib files into the lib folder ?
I noticed with 5.8.0 there are some changes in the required libs (which I didnt require earlier for my 5.7.0 installation)
Yes, I have installed resource adapter and also copied the requreid files in the lib folder.
I am not sure deploying Active MQ web console in Glassfiosh is really mandatory activity?
We can run connect to Active MQ Web UI seperately, without glassfish?
Yes, the console is not mandatory.
You get the same error through the admin console ? What error stack you get in the server.log ?