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

            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 閱讀(276) 評論(0)  編輯  收藏 所屬分類: JMS

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


          網站導航:
           
          主站蜘蛛池模板: 新化县| 那坡县| 湘西| 九寨沟县| 仁寿县| 大名县| 洛阳市| 仁怀市| 康保县| 额尔古纳市| 崇信县| 桃园县| 城固县| 楚雄市| 景洪市| 遂宁市| 甘洛县| 樟树市| 饶阳县| 河西区| 江孜县| 米林县| 九江县| 汝阳县| 娱乐| 衡阳县| 康平县| 嘉峪关市| 济源市| 化德县| 汝城县| 台湾省| 泗洪县| 左权县| 永嘉县| 东至县| 临沭县| 隆回县| 达州市| 天等县| 邵东县|