example16messagedrivenbean.java

《精通Spring》源代码

/*
 * Created on 2004-12-25
 *
 * http://www.open-v.com 提供代码的维护工作
 */
package com.openv.spring;

import org.springframework.ejb.support.AbstractJmsMessageDrivenBean;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.TextMessage;


/**
 * Example16MessageDrivenBean MDB
 *
 * @author luoshifei
 */
public class Example16MessageDrivenBean extends AbstractJmsMessageDrivenBean {
    private ISBusinessExample16 sbe;

    protected void onEjbCreate() {
        //简化处理Spring。即本实例参考本书SBusinessExample16Bean中Spring的用法。
        System.out.println("onEjbCreate().............");
        sbe = (ISBusinessExample16) getBeanFactory().getBean("sbe16");
    }

    public void onMessage(Message message) {
        System.out.println("onMessage()................");

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

            try {
                System.out.println(sbe.getStr(tm.getText()));
            } catch (JMSException e) {
                System.out.println(e.getMessage());
            }
        }
    }
}