topicprintbeanone.java

精通EJB3源码

package com.foshanshop.ejb3.impl;

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

@MessageDriven(mappedName="topic/chatTopic",activationConfig =
{
  @ActivationConfigProperty(propertyName="destinationType",
    propertyValue="javax.jms.Topic")
})
public class TopicPrintBeanOne implements MessageListener{
    
    public void onMessage(Message msg) {
        try {            
            TextMessage tmsg = (TextMessage) msg;
            String content = tmsg.getText();
            System.out.println(this.getClass().getName()+"=="+ content);              
        } catch (Exception e){
            e.printStackTrace();
        }
    }
}