Overview

The latest stable release for JBoss Application Server (AS) is 4.2.3 and JBoss Messaging is 1.4.0 SP3

JBoss Messaging is the new messaging system from JBoss and it is a complete rewrite and replacement for JBossMQ.

JBoss AS 4.2 comes with JBossMQ but it is compatible with JBoss Messaging and JBossMQ can be replaced with it. It is dependent on Java 5.

JBoss Messaging can currently run under JBoss AS 4.2.0.GA or later. In the future it will also be available under JBoss Microcontainer.

Evaluation

Licensing

Open-source solution.

Successful implementations

Reliability

Strong focus on reliability. No single point of failure.

Scalability

Highly Scalable and supports clustering. Allows distribution of load across cluster, balancing CPU cycles. No single point of failure. High Throughput and low latency.

Managability / Configurability

Highly configurable.

Provides point to point and publish/subscribe messaging models.

Configurable DLQs and Expiry Queues.

Allows the use of very large queues (too large to fit in memory) by automatic paging of messages to storage.

Message Bridge: Enables bridging of messages between any two JMS1.1 destinations.

Fully integrated with JBoss Transactions.

Performance

Active Developer Community

Product Maturity

JBoss Messaging released on Mar 29, 2006

Standards Support (AMQP, JMS, XMPP, STOMP)

Future versions will support AMQP. There is a commitment to move in that direction.

Fully Supports JMS 1.1

Developer Toolkit / API

Provides the javax.jms namespace to create message producers, consumers and listeners etc.

Sample code is provided below for sending/receiving to a remote topic (used to broadcast messages for publish/subscribe model)

         ic = new InitialContext();
        
         ConnectionFactory cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
         Topic topic = (Topic)ic.lookup(destinationName);
         log("Topic " + destinationName + " exists");
        
         connection = cf.createConnection();
         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
         MessageProducer publisher = session.createProducer(topic);
         MessageConsumer subscriber = session.createConsumer(topic);
        
         ExampleListener messageListener = new ExampleListener();
         subscriber.setMessageListener(messageListener);
         connection.start();
        
         TextMessage message = session.createTextMessage("Hello!");
         publisher.send(message);
         log("The message was successfully published on the topic");
        
         messageListener.waitForMessage();
        
         message = (TextMessage)messageListener.getMessage();
         log("Received message: " + message.getText());
         assertEquals("Hello!", message.getText());
        
         displayProviderInfo(connection.getMetaData());