少年阿賓

          那些青春的歲月

            BlogJava :: 首頁 :: 聯(lián)系 :: 聚合  :: 管理
            500 Posts :: 0 Stories :: 135 Comments :: 0 Trackbacks

          常用鏈接

          留言簿(22)

          我參與的團(tuán)隊(duì)

          搜索

          •  

          最新評(píng)論

          閱讀排行榜

          評(píng)論排行榜

          package org.abin.lee.activemq;

          import javax.jms.Connection;
          import javax.jms.ConnectionFactory;
          import javax.jms.DeliveryMode;
          import javax.jms.Destination;
          import javax.jms.MapMessage;
          import javax.jms.MessageProducer;
          import javax.jms.Session;

          import org.apache.activemq.ActiveMQConnection;
          import org.apache.activemq.ActiveMQConnectionFactory;

          public class MapSender {

           private static final int SEND_NUMBER = 5;

           public static void main(String[] args) {
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
              ActiveMQConnection.DEFAULT_USER,
              ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
            Connection connection = null;
            Session session;
            Destination destination = null;
            MessageProducer messageProducer;
            try {
             connection=connectionFactory.createConnection();
             connection.start();
             session=connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
             destination=session.createQueue("FirstQueue");
             messageProducer=session.createProducer(destination);
             messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
             
             MapMessage map=session.createMapMessage();
             map.setBoolean("flag", true);
             map.setDouble("dou", 1.01);
             map.setInt("zx", 88);
             map.setString("zifu", "zzzzzz");
             messageProducer.send(map);
             session.commit();
            } catch (Exception e) {
             e.printStackTrace();
            }
           }


          }






          package org.abin.lee.activemq;

          import javax.jms.Connection;
          import javax.jms.ConnectionFactory;
          import javax.jms.Destination;
          import javax.jms.MapMessage;
          import javax.jms.MessageConsumer;
          import javax.jms.Session;

          import org.apache.activemq.ActiveMQConnection;
          import org.apache.activemq.ActiveMQConnectionFactory;

          public class MapReceiver {public static void main(String[] args) {
           ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
             ActiveMQConnection.DEFAULT_USER,
             ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
           Connection connection = null;
           Session session;
           Destination destination;
           MessageConsumer consumer;
           try {
            connection = connectionFactory.createConnection();
            connection.start();
            session = connection.createSession(Boolean.FALSE,
              Session.AUTO_ACKNOWLEDGE);
            destination = session.createQueue("FirstQueue");
            consumer = session.createConsumer(destination);
            while(true){
             MapMessage map=(MapMessage)consumer.receive(500000);
             if (null != map) {
              boolean flag=map.getBoolean("falg");
              System.out.println("AcitveMQ 接收到的消息  flag="+flag);
              double dou=map.getDouble("dou");
              System.out.println("AcitveMQ 接收到的消息  dou="+dou);
              int zx=map.getInt("zx");
              System.out.println("AcitveMQ 接收到的消息  zx="+zx);
              String zifu=map.getString("zifu");
              System.out.println("AcitveMQ 接收到的消息  zifu="+zifu);
             }else
              break;

            }
            
             

           } catch (Exception e) {
            e.printStackTrace();
           }

          }
          }

          posted on 2012-08-02 16:35 abin 閱讀(877) 評(píng)論(0)  編輯  收藏 所屬分類: ActiveMQ

          只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。


          網(wǎng)站導(dǎo)航:
           
          主站蜘蛛池模板: 繁峙县| 商城县| 开原市| 石阡县| 井冈山市| 磐石市| 临沂市| 岗巴县| 怀来县| 磐安县| 沾化县| 澄江县| 湄潭县| 织金县| 怀来县| 灵武市| 兴仁县| 贡山| 南丹县| 卢氏县| 双城市| 页游| 临泽县| 永修县| 洛南县| 禹州市| 铁岭县| 威远县| 莱西市| 稷山县| 灵川县| 宝鸡市| 克山县| 涟源市| 陇南市| 通渭县| 大宁县| 娄烦县| 五寨县| 泊头市| 礼泉县|