messagedrivenbeanexampleejb30nonspring.java

随书光盘：精通Sping 2.0 的随书源代码

package test.ejb3;

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

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;


/**
 * 
 * @author worldheart
 *
 */
@MessageDriven(activationConfig = {
		@ActivationConfigProperty(propertyName = "ConnectionFactoryJndiName", 
				propertyValue = "jms/TopicConnectionFactory"),
		@ActivationConfigProperty(propertyName = "DestinationName", 
				propertyValue = "jms/demoTopic"),
		@ActivationConfigProperty(propertyName = "DestinationType", 
				propertyValue = "javax.jms.Topic")
		})
public class MessageDrivenBeanExampleEjb30NonSpring implements javax.jms.MessageListener {
	
	protected static final Log log = LogFactory.getLog(MessageDrivenBeanExampleEjb30NonSpring.class);
	
    public void onMessage(Message message) {
        log.info("onMessage()................");

        if (message instanceof TextMessage) {
            TextMessage tm = (TextMessage) message;

            try {      	
                log.info(tm.getText());
            } catch (JMSException e) {
                log.error(e.getMessage());
            }
            
        }
        
    }
}