msglistener.java

来自「weblogic应用全实例」· Java 代码 · 共 55 行

//声明这个类所在的包为examples.jms.startup
package examples.jms.startup;
//声明这个类引入的其它类和包
import javax.jms.*;

/**
 * 这个实例实现消息监听器接口，WebLogic服务器能管理一个消息监听池。
 * 这个类被PoolReceive实例使用。
 */

public class MsgListener
  implements MessageListener
{
  //消息监听器的数量
  private static int listenerCounter=0;  
  //一个特定监听器的Id
  private int listenerId; 
  //构造方法
  public MsgListener()
  {
    //分配新的Id
    this.listenerId = ++listenerCounter;
  }

  /** 实现消息监听接口MessageListener定义的方法
    * @参数 msg 消息
    */
  public void onMessage(Message msg)
  {
    try {
      //消息文本
      String msgText;
      if (msg instanceof TextMessage) {
        //文本消息，获取文本
        msgText = ((TextMessage)msg).getText();
      } else {
        msgText = msg.toString();
      }
      System.out.println("MsgListener["+listenerId+"] : JMS Message="+ msgText);

      try {
        Thread.sleep(1000);
      } catch (InterruptedException ie) {}
    } catch (JMSException jmse) {
      jmse.printStackTrace();
    }
  }


}