msgreceiver.java~1~

模拟工作流的代码

package wsfsimulator;

import java.util.Hashtable;
import javax.naming.*;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.management.*;
import org.jboss.system.*;
import javax.jms.*;

import com.zte.ums.uep.util.mml.parser.*;
import com.zte.ums.uep.caf.fm.common.*;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class MsgReceiver
    implements MessageListener {

  private int messageCount;
  private Context context = null;
  private TopicConnectionFactory connectionFactory = null;
  private TopicConnection connection = null;
  private TopicSession sessionMss = null;
  private Topic topicMss = null;
  private TopicSubscriber subscriberMss = null;

  public MsgReceiver() {
    messageCount = 0;
    loginJms();
  }

  public void loginJms() {
    Hashtable props = new Hashtable();
    props.put(Context.INITIAL_CONTEXT_FACTORY,
              "org.jnp.interfaces.NamingContextFactory");
    props.put(Context.PROVIDER_URL, "127.0.0.1");
    props.put("java.naming.rmi.security.manager", "yes");
    props.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");

    try {
      context = new InitialContext(props);
      connectionFactory = (TopicConnectionFactory) context.lookup(
          "ConnectionFactory");
      connection = connectionFactory.createTopicConnection();
      sessionMss = connection.createTopicSession(false,
                                                 Session.AUTO_ACKNOWLEDGE);
      topicMss = (Topic) context.lookup("topic/" + IEventConst.CAF_2WSF_Topic);
      subscriberMss = sessionMss.createSubscriber(topicMss);
      subscriberMss.setMessageListener(this);
      connection.start();
    }
    catch (Exception e) {
      e.printStackTrace();
      System.out.println("login failed");
      return;
    }

  }

  public void onMessage(Message msg) {
    Topic topic = null;
    FMessage fmsg = null;
    int commandCode;
    try {
      if (msg instanceof ObjectMessage) {
        ObjectMessage omsg = (ObjectMessage) msg;
        fmsg = (FMessage) omsg.getObject();
        RecSection section = (RecSection) fmsg.getSectionAt(0);
        String[] record = null;
        record = section.getRecordAt(0);
        System.out.println(fmsg.toString());
        messageCount++;
        if (messageCount == 1000 || messageCount == 1) {
          System.out.println(System.currentTimeMillis());
        }
      }
      else {
        System.out.println("wrong message type");
      }
    }
    catch (JMSException e) {
      e.printStackTrace();
    }
    fmsg = null;
    msg = null;
  }

}