topicprintbeanone.java

jboss4 + Mysql +ejb3.0 EJB3 简单例子

/**
 * Copyright (c)上海烟草(集团)公司与上海康时信息系统有限公司。
 */
package com.myejb;

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

/**
 * 
 * @author xywang
 * @since 2009-2-18
 * @version 1.0
 * 
 */
@MessageDriven(activationConfig={
        @ActivationConfigProperty(propertyName="destinationType",propertyValue="javax.jms.Topic"),
        @ActivationConfigProperty(propertyName="destination",propertyValue="topic/chatTopic1"),
})
public class TopicPrintBeanOne implements MessageListener{

    /*
     * （非 Javadoc）
     * 
     * @see javax.jms.MessageListener#onMessage(javax.jms.Message)
     */
    public void onMessage(Message msg){
        TextMessage tmsg = (TextMessage) msg;
        try{
            String content = tmsg.getText();
            System.out.println(this.getClass().getName() + "==" + content);
        }catch(JMSException e){
            e.printStackTrace();
        }

    }

}