从jboss 7.1连接到JMS (Apacher ServiceMix)

   <hornetq-server>

       <persistence-enabled>true</persistence-enabled>

       <journal-file-size>102400</journal-file-size>

       <journal-min-files>2</journal-min-files>

       <journal-pool-files>10</journal-pool-files>

       <connectors>

           <netty-connector name="netty" socket-binding="messaging"/>

       </connectors>

       <acceptors>

           <netty-acceptor name="netty" socket-binding="messaging"/>

       </acceptors>

       <security-settings>

           <security-setting match="#">

               <permission type="send" roles="guest"/>

               <permission type="consume" roles="guest"/>

               <permission type="createNonDurableQueue" roles="guest"/>

               <permission type="deleteNonDurableQueue" roles="guest"/>

           </security-setting>

       </security-settings>

       <address-settings>

           <address-setting match="#">

               <dead-letter-address>jms.queue.DLQ</dead-letter-address>

               <expiry-address>jms.queue.ExpiryQueue</expiry-address>

               <redelivery-delay>0</redelivery-delay>

               <max-delivery-attempts>10</max-delivery-attempts>

               <max-size-bytes>10485760</max-size-bytes>

               <address-full-policy>BLOCK</address-full-policy>

               <message-counter-history-day-limit>10</message-counter-history-day-limit>

           </address-setting>

       </address-settings>

       <jms-connection-factories>

           <connection-factory name="RemoteConnectionFactory">

               <connectors>

                   <connector-ref connector-name="netty"/>

               </connectors>

               <entries>

                   <entry name="java:/jms/RemoteConnectionFactory"/>

               </entries>

           </connection-factory>

       </jms-connection-factories>

       <jms-destinations>

           <jms-queue name="ExampleQueue">

               <entry name="java:/jms/queue/ExampleQueue"/>

           </jms-queue>

       </jms-destinations>

   </hornetq-server>

   public static void main(String[] args) {

       try {

           // 创建JNDI上下文

           Context jndiContext = new InitialContext();

           // 查找JMS连接工厂

           ConnectionFactory connectionFactory = (ConnectionFactory) jndiContext.lookup("java:/jms/RemoteConnectionFactory");

           // 创建JMS连接

           Connection connection = connectionFactory.createConnection();

           // 创建JMS会话

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

           // 查找JMS队列

           Destination destination = (Destination) jndiContext.lookup("java:/jms/queue/ExampleQueue");

           // 创建JMS消息生产者

           MessageProducer producer = session.createProducer(destination);

           // 创建JMS消息

           Message message = session.createTextMessage("Hello, JMS!");

           // 发送JMS消息

           producer.send(message);

           // 创建JMS消息消费者

           MessageConsumer consumer = session.createConsumer(destination);

           // 接收JMS消息

           Message receivedMessage = consumer.receive();

           // 处理接收到的JMS消息

           if (receivedMessage instanceof TextMessage) {

               TextMessage textMessage = (TextMessage) receivedMessage;

               System.out.println("Received message: " + textMessage.getText());

           }

           // 关闭JMS资源

           consumer.close();

           producer.close();

           session.close();

           connection.close();

       } catch (NamingException | JMSException e) {

           e.printStackTrace();

       }

   }