古之成大事者,不唯有超世之才,亦唯有堅韌不拔之志也!

            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
            3 隨筆 :: 44 文章 :: 1 評論 :: 0 Trackbacks
          1:JMS的使用類似于JDBC ,SUN只是提出一個規范接口,由不同的MOM廠商實現。

          2: MQ 啟動后應用程序可以獨立的操作JMS接口,應用程序并不依賴于容器,如JBOSS。直接通過jndi訪問MQ。

          3:使用JBOSS的MQ應用程序需要包含如下jar文件:
            

          4:JBOSS默認的MQ訪問端口為1099 "jnp://127.0.0.1:1099"

          5: 使用實例

          創建 TOPIC PUBLISHER
           

           1         Hashtable props = new Hashtable();
           2         props.put(Context.INITIAL_CONTEXT_FACTORY,
           3                 "org.jnp.interfaces.NamingContextFactory");
           4         props.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099"); 
           5         props.put("java.naming.rmi.security.manager""yes");
           6         props.put(Context.URL_PKG_PREFIXES, "org.jboss.naming");
           7         Context jndiContext = new InitialContext(props);
           8         //從JNDI得ConnectionFactory
           9         TopicConnectionFactory topicFactory = (TopicConnectionFactory) jndiContext
          10                 .lookup(factoryJNDI);
          11         //用ConnectionFactory創建連接
          12         topicConnection = topicFactory.createTopicConnection();
          13         //使用連接創建會話
          14         topicSession = topicConnection.createTopicSession(false,
          15                 Session.AUTO_ACKNOWLEDGE);
          16         //查找JNDI topic并使用會話創建之
          17         topic = (Topic) jndiContext.lookup(topicJNDI);
          18         topicPublisher = topicSession.createPublisher(topic);

          創建 TOPIC SUBSCRIBER
           

                  //創建Subscriber
                  topicSubscriber = topicSession.createSubscriber(topic);
                  
          //注冊MessageListener 必須實現onMessage方法
                  topicSubscriber.setMessageListener(this);
                  topicConnection.start();
          posted on 2009-02-06 17:20 goto 閱讀(272) 評論(0)  編輯  收藏 所屬分類: JMS

          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 左权县| 台安县| 榆树市| 迁西县| 宁城县| 正宁县| 东乡县| 湟中县| 交口县| 那坡县| 凌源市| 五华县| 南木林县| 阿拉善左旗| 英德市| 宜兰县| 突泉县| 来凤县| 荔波县| 亚东县| 临洮县| 乌苏市| 渭源县| 玉林市| 荔波县| 三门县| 黄石市| 平顺县| 和平区| 米易县| 洛宁县| 兰西县| 南汇区| 连南| 攀枝花市| 闽侯县| 潞西市| 青河县| 和平县| 甘肃省| 武义县|