JMS + jboss EAP 6.2 示例

 package org.jboss.as.quickstarts.jms;

 import java.util.Hashtable;

 import javax.jms.Connection;

 import javax.jms.ConnectionFactory;

 import javax.jms.Destination;

 import javax.jms.JMSException;

 import javax.jms.MessageConsumer;

 import javax.jms.MessageProducer;

 import javax.jms.Session;

 import javax.jms.TextMessage;

 import javax.naming.Context;

 import javax.naming.InitialContext;

 import javax.naming.NamingException;

 public class JbossJMSTest {

     public static void main(String[] args) throws NamingException, JMSException {

         final String lOOKUP_CONNECTION_FACTORY_NAME = "lookup.connectionfactory.name";

         final String lOOKUP_DESTINATION_NAME = "lookup.destination.name";

         ConnectionFactory connectionFactory = null;

         Connection connection = null;

         Session session = null;

         MessageProducer producer = null;

         MessageConsumer consumer = null;

         Destination destination = null;

         TextMessage message = null;

         Context context = null;

         try {

             // 建立上下文（預設會從應用的classpath下載入jndi.properties做為環境引數）

             context = new InitialContext();

             // 把環境引數取出來，後面會用到

             Hashtable<String, String> env = (Hashtable<String, String>) context

                     .getEnvironment();

             // 查詢連線工廠

             connectionFactory = (ConnectionFactory) context.lookup(env

                     .get(lOOKUP_CONNECTION_FACTORY_NAME));

             // 查詢目標佇列

             destination = (Destination) context.lookup(env

                     .get(lOOKUP_DESTINATION_NAME));

             // 建立連線

             connection = connectionFactory.createConnection(

                     env.get(Context.SECURITY_PRINCIPAL),

                     env.get(Context.SECURITY_CREDENTIALS));

             // 建立會話

             session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

             // 建立生產者(即傳送者)

             producer = session.createProducer(destination);

             // 建立消費者(即接收者)

             consumer = session.createConsumer(destination);

             // 開始連線

             connection.start();

             // 傳送訊息

             message = session.createTextMessage("菩提樹下的楊過，歡迎使用JMS!");

             producer.send(message);

             // 接收訊息

             message = (TextMessage) consumer.receive(5000);

             // 列印訊息

             System.out.println(message.getText());

         } catch (NamingException e) {

             e.printStackTrace();

         } catch (JMSException e) {

             e.printStackTrace();

         } finally {

             // 釋放資源

             if (context != null) {

                 context.close();

             }

             if (connection != null) {

                 connection.close();

             }

         }

     }

 }

 <?xml version="1.0"?>

 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

     <modelVersion>4.0.0</modelVersion>

     <groupId>cnblogs</groupId>

     <artifactId>helloworld-jms</artifactId>

     <version>1.0</version>

     <packaging>jar</packaging>

     <properties>

         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

     </properties>

     <dependencies>

         <dependency>

             <groupId>org.jboss.as</groupId>

             <artifactId>jboss-as-jms-client-bom</artifactId>

             <version>7.2.0.Final-redhat-8</version>

             <type>pom</type>

         </dependency>

     </dependencies>

 </project>