messagebean.java

来自「这个是学习EJB的好例子,里面有许多关于EJB Bean的」· Java 代码 · 共 34 行

package com.cws.ejb.message;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

@MessageDriven(activationConfig =
{
	//@ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
	//@ActivationConfigProperty(propertyName="destination",	propertyValue="queue/cwsQueue")
	@ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Topic"),
	@ActivationConfigProperty(propertyName="destination", propertyValue="topic/cwsTopic")
})
public class MessageBean implements MessageListener {
	
	public void onMessage(Message msg) {
		try {
	
			TextMessage tmsg = (TextMessage) msg;			
			this.print(tmsg.getText());
		} 
		catch (Exception e) {
			
			e.printStackTrace();
		}
	}
	
	private void print(String content){

		System.out.println(content);
	}
}