亚洲熟妇AV乱码在线观看,亚洲AV无一区二区三区久久,亚洲高清中文字幕

在JMS的Connection Factories 中新建一個連接工廠
在Stores中新建一個存儲空間，可以為jdbc或者file類型
在Servers中新建一個Server
展開剛才創建的DemoJMSServer，新建一個Destinations，其中有2種類型，queue：點對點方式，topic：廣播方式給所有的MDB
在jb中新建一個MDB，transaction type:bean ，Destination type:javax.jms.Queue，在Destination name中輸入剛才在weblogic的jms里面建立的目標名稱，Pool properties的Maximum pool size:10
在onMessage方法中加入代碼
public?void?onMessage(Message?msg){?
try?{

??????TextMessage?TMS?=?(TextMessage)?msg;

??????String?a1?=?TMS.getText();

??????String?b1?=?a1;

??????System.out.println("Message?getted?Is?:"?+?a1?+?">>>>>>>>>>>OK");

??????Context?context?=?new?InitialContext();

??????Object?ref?=?context.lookup("Sess");? //session bean的本地接口

??????SessHome?sessHome?=?(SessHome)?PortableRemoteObject.narrow(ref,?SessHome.class);

??????sessHome.create().insTableAa11(a1,?b1);

??????//這是通過Session?Bean的insTableAa11調用EntityBean的ejbHomeEjbInsertAa11

??????//功能其是很簡單，插入Aa11表一條記錄(a1,a1)

????}

????catch?(Exception?ex)?{

??????ex.printStackTrace();

????}
}
deploy這個消息驅動Bean
new一個MDBTestClient class
package?bmpsessmdb;
import?java.util.*;

import?javax.jms.*;

import?javax.naming.*;

public?class?MDBTestClient?{
????public?final?static?String

??????JNDI_FACTORY?=?"weblogic.jndi.WLInitialContextFactory";

??public?final?static?String?URL?=?"t3://127.0.0.1:7001";

??private?static?final?String?QUEUE_CONNECTION_FACTORY?=

??????"DemoJMSConnectionFactory";

??private?static?final?String?QUEUE?=?"DemoJMSQueue";

??private?static?InitialContext?getInitialContext(String?url)?throws

??????NamingException?{

????Hashtable?env?=?new?Hashtable();

????env.put(Context.INITIAL_CONTEXT_FACTORY,?JNDI_FACTORY);

????env.put(Context.PROVIDER_URL,?url);

????return?new?InitialContext(env);

??}

??public?static?void?main(String[]?args)?throws?Exception?{

????Context?ctx?=?getInitialContext(URL);

????QueueConnectionFactory?qConnFact?=

????(QueueConnectionFactory)?ctx.lookup(QUEUE_CONNECTION_FACTORY);

????QueueConnection?qConn?=?qConnFact.createQueueConnection();

????QueueSession?qSess?=?qConn.createQueueSession(false,

??????????????????????????????????????????????????Session.AUTO_ACKNOWLEDGE);

????Queue?q?=?(Queue)?ctx.lookup(QUEUE);

????QueueSender?qSend?=?qSess.createSender(q);

????TextMessage?txtMsg?=?qSess.createTextMessage("songtx3");

????System.out.println("Sending?a?message?to?queue");

????qSend.send(txtMsg);

????//---------------------------------------------------------//

????txtMsg?=?qSess.createTextMessage("songtx4");

????System.out.println("Sending?a?message?to?queue");

????qSend.send(txtMsg);

????//---------------------------------------------------------//

????qConn.close();

????System.exit(0);

??}

}
運行測試，over

posted on 2006-03-23 14:51 luckyrobbie 閱讀(1556) 評論(0) 編輯收藏所屬分類: Tomcat & Weblogic


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




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: Weblogic JMS 的配置和MDB的應用(聽課筆記) Tomcat 和 Weblogic 中配置application的安全策略(聽課筆記)

牛仔褲的夏天

公告

常用鏈接

留言簿(1)

隨筆分類

隨筆檔案

文章檔案

連接

搜索

最新評論

閱讀排行榜

評論排行榜