messagedrivenbeanexampleejb30.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;
import org.springframework.ejb.support.AbstractJmsMessageDrivenBean;


/**
 * 
 * @author worldheart
 *
 */
@MessageDriven(activationConfig = {
		@ActivationConfigProperty(propertyName = "ConnectionFactoryJndiName", 
				propertyValue = "jms/QueueConnectionFactory"),
		@ActivationConfigProperty(propertyName = "DestinationName", 
				propertyValue = "jms/demoQueue"),
		@ActivationConfigProperty(propertyName = "DestinationType", 
				propertyValue = "javax.jms.Queue")
		})
public class MessageDrivenBeanExampleEjb30 extends AbstractJmsMessageDrivenBean {
	
	protected static final Log log = LogFactory.getLog(MessageDrivenBeanExampleEjb30.class);
	
    private IBusinessInterface sbe;

    protected void onEjbCreate() {
    	log.info("onEjbCreate().............");
        sbe = (IBusinessInterface) getBeanFactory().getBean("bi");
    }

    public void onMessage(Message message) {
        log.info("onMessage()................");

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

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