1.注意在写MDB程序的时候,如果是使用的P2P方式的话,可能你写了多个同样的MDBbean,但是
只会有一个MDBbean被调用,至于是哪一个被调用是随机的,这时候其他的将不会起作用;
一个消息的发送者,只会有一个消息的接收者
2.注意在写MDB程序的时候,如果是使用PubSub模式的访问服务器方式的话,那么如果有多个相
同的MDBBean,都会被调用,也就是一个消息的发送者,可以有很多个消息的订阅者收到消息
3.示例程序
新建EJB3.0项目:EJBTestP2PANDPubSub_05
a.编写客户端的MDBbean
在com.credream.ejb包下写:
MyQueueMDBBean.java
MyQueueMDBBean02.java
注意:这两个MDBbean的区别在于:System.out.println(" MyQueueMDBBean02被调用了
package com.credream.ejb;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
@MessageDriven(//通过这个说明这是mdbbean
activationConfig={//值是一个数组;
@ActivationConfigProperty
(propertyName="destinationType",propertyValue="javax.jms.Queue"),
@ActivationConfigProperty
(propertyName="destination",propertyValue="queue/myqueue")//没有这个名词的queue的
时候,就会创建一个,
//就是通过这个名词得到destination;
}
)
public class MyQueueMDBBean implements MessageListener {
public void onMessage(Message msg) {
TextMessage textMessage=(TextMessage)msg;
try {
System.out.println(" MyQueueMDBBean被调用了:[["
+textMessage.getText()+"]]");
} catch (JMSException e) {
e.printStackTrace();
}
}
}
--------------------------------------------------------
MyTopicMDBBean.java
MyTopicMDBBean02.java
MyTopicMDBBean03.java
这三个的结果区别在于:System.out.println(" MyTopicMDBBean02/ MyTopicMDBBean03被调
用了:[["
package com.credream.ejb;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
@MessageDriven(//通过这个说明这是mdbbean
activationConfig={//值是一个数组;
@ActivationConfigProperty
(propertyName="destinationType",propertyValue="javax.jms.Topic"),
@ActivationConfigProperty
(propertyName="destination",propertyValue="topic/mytopic")//没有这个名词的queue的
时候,就会创建一个,
//就是通过这个名词得到destination;
}
)
public class MyTopicMDBBean implements MessageListener {
public void onMessage(Message msg) {
TextMessage textMessage=(TextMessage)msg;
try {
System.out.println(" MyTopicMDBBean被调用了:[["
+textMessage.getText()+"]]");
} catch (JMSException e) {
e.printStackTrace();
}
}
}
-----------------------------------------------------------------------