package mymdb;
import javax.ejb.*;
import javax.jms.*;
import javax.naming.*;
public class mdbHelloBean implements MessageDrivenBean, MessageListener {
MessageDrivenContext messageDrivenContext;
public void ejbCreate() throws CreateException {
/**@todo Complete this method*/
}
public void ejbRemove() {
/**@todo Complete this method*/
}
public void onMessage(Message msg) {
String msgReceive = null;
try {
//获取消息的内容
msgReceive = ( (TextMessage) msg).getText();
}
catch (JMSException e) {
e.printStackTrace();
}
StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("the message is:");
stringBuffer.append(msgReceive);
System.out.println(stringBuffer.toString());//输出消息
}
public void setMessageDrivenContext(MessageDrivenContext messageDrivenContext) {
this.messageDrivenContext = messageDrivenContext;
}
}