牛仔裤的夏天
JAVA是蓝色的-
online
BlogJava
::
首页
::
新随笔
::
联系
::
聚合
::
管理
::
30 随笔 :: 5 文章 :: 15 评论 :: 0 Trackbacks
<
2006年3月
>
日
一
二
三
四
五
六
26
27
28
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
1
2
3
4
5
6
7
8
公告
常用链接
我的随笔
我的评论
我的参与
最新评论
留言簿
(1)
给我留言
查看公开留言
查看私人留言
随笔分类
Java(5)
(rss)
Others(4)
(rss)
Struts & Hibernate(9)
(rss)
Tomcat & Weblogic(2)
(rss)
XML(2)
(rss)
贝贝的故事(8)
(rss)
随笔档案
2006年6月 (1)
2006年4月 (3)
2006年3月 (20)
2006年2月 (1)
2006年1月 (3)
2005年12月 (2)
文章档案
2006年3月 (2)
2006年2月 (1)
2006年1月 (1)
2005年12月 (1)
连接
InputKing在线中文输入
java录像
面试题目
搜索
最新评论
1. re: struts中<html:messages>标签的使用
4年前写的了,早忘记了
--luckyrobbie
2. re: struts中<html:messages>标签的使用
写的很好就是没用啊 我弄了好久它怎么都不出来..
--还在睡觉的幽灵
3. re: 有关ant的faq
default.properties under ant source code
--thomas sabo charm
4. re: struts中<html:messages>标签的使用[未登录]
kkk
--kkk
5. re: struts中<html:messages>标签的使用
hdfd
--nn
阅读排行榜
1. 一个取到ResultSet后返回Iterator的例子(5444)
2. struts中<html:messages>标签的使用(2124)
3. 复习一遍aix操作(2002)
4. Weblogic JMS 的配置和MDB的应用(听课笔记)(1549)
5. 显示结果集的标签(1152)
评论排行榜
1. 一个取到ResultSet后返回Iterator的例子(6)
2. struts中<html:messages>标签的使用(4)
3. 学习 xpath 的2个网站(3)
4. 显示结果集的标签(1)
5. 打电话(0)
Weblogic JMS 的配置和MDB的应用(听课笔记)
在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
阅读(1549)
评论(0)
编辑
收藏
所属分类:
Tomcat & Weblogic
新用户注册
刷新评论列表
只有注册用户
登录
后才能发表评论。
网站导航:
博客园
IT新闻
知识库
C++博客
博问
管理
相关文章:
Weblogic JMS 的配置和MDB的应用(听课笔记)
Tomcat 和 Weblogic 中配置application的安全策略(听课笔记)
Powered by:
BlogJava
Copyright © luckyrobbie