iiopevent.java

利用JAVA采用IIOP通讯的方式,支持weblogic及websphere

/*
 * IIopEvent.java
 *
 * Created on 2004年1月2日, 下午1:59
 */

package collector.iiop;

import java.rmi.*;
import java.util.*;
import javax.ejb.*;
import javax.naming.*;
import javax.rmi.*;

import collector.common.*; //import pbs.sessionbean.event.*;//import pbs.sessionbean.event.*;//import pbs.sessionbean.event.*;//import pbs.sessionbean.event.*;//import pbs.sessionbean.event.*;//import pbs.sessionbean.event.*;
//import pbs.sessionbean.event.*;
import pbs.sessionbean.ejb.*;

/**
 *
 * @author  wj
 */
public class IIopEvent {

  /** Creates a new instance of IIopEvent */
  private ProcessEvent m_ProcessEvent = null;
  private ProcessEventHome m_ProcessEventHome = null;

  private String m_InitContextFac = null;
  private String m_IIopURL = null;
  private String m_JndiName = null;

  private Context m_Context = null;
  private Object m_Object = null;

  /** Creates a new instance of IiopComm */
  public IIopEvent() {
//        m_ProcessEvent = null;
  }

  public int setIIopParam(String m_InitContextFac, String m_IIopURL,
                          String m_JndiName) {
    this.m_InitContextFac = m_InitContextFac;
    this.m_IIopURL = m_IIopURL;
    this.m_JndiName = m_JndiName;

    return 1;
  }

  public int initConnect() {
    try {
      Properties m_Env = new Properties();
      m_Env.put(javax.naming.Context.INITIAL_CONTEXT_FACTORY, m_InitContextFac);
      m_Env.put(javax.naming.InitialContext.PROVIDER_URL, m_IIopURL);
//      m_Env.put("java.naming.factory.initial", m_InitContextFac);
//      m_Env.put("java.naming.provider.url", m_IIopURL);

      //CollectorDefine.SystemPrintln ("START TO INITIAL CONTEXT 。。。");
      m_Context = new InitialContext(m_Env);

      //CollectorDefine.SystemPrintln ("START TO LOOKUP 。。。");
      m_Object = m_Context.lookup(m_JndiName);
      m_ProcessEventHome = (ProcessEventHome) PortableRemoteObject.narrow(
          m_Object, ProcessEventHome.class);

      //CollectorDefine.SystemPrintln ("START TO CREATE ");
//            this.m_ProcessEvent = null;
///            this.m_ProcessEvent = m_ProcessEventHome.create ();

      CollectorDefine.SystemPrintln("IIOP SUCCESS !!" + "url : " + m_IIopURL +
                                    "m_JndiName : " + m_JndiName);

    }
    catch (Exception m_Exception) {
      CollectorDefine.SystemPrintln(" Caught an unexpected exception!" +
                                    m_Exception.getMessage());
      CFunction.writeLog(" Caught an unexpected exception!", m_Exception);
      return -1;
    }

    return 1;
  }

  public int reConnect() {
    try {
      m_Object = m_Context.lookup(m_JndiName);
      m_ProcessEventHome = (ProcessEventHome) PortableRemoteObject.narrow(
          m_Object, ProcessEventHome.class);

      //CollectorDefine.SystemPrintln ("START TO CREATE ");
//            this.m_ProcessEvent = null;
//            this.m_ProcessEvent = m_ProcessEventHome.create ();

      CollectorDefine.SystemPrintln("IIOP SUCCESS !!" + "url : " + m_IIopURL +
                                    "m_JndiName : " + m_JndiName);

    }
    catch (Exception m_Exception) {
      CollectorDefine.SystemPrintln(" Caught an unexpected exception!" +
                                    m_Exception.getMessage());
      CFunction.writeLog(" Caught an unexpected exception!", m_Exception);
      return -1;
    }

    return 1;
  }

  public ProcessEvent connect() throws CreateException, RemoteException {
    this.m_ProcessEvent = m_ProcessEventHome.create();
    return m_ProcessEvent;
  }

  public int close() throws RemoteException, RemoveException {
    if (this.m_ProcessEvent != null) {
      this.m_ProcessEvent.remove();
      this.m_ProcessEvent = null;
    }

    return 1;
  }

  public int setDebugNo(int debug_no) {
    try {
      this.m_ProcessEvent.setDebugNo(debug_no);
    }
    catch (java.rmi.RemoteException m_RemoteException) {
      CFunction.writeLog("setDebugNo In IIopEvent Error #1 ,",
                         m_RemoteException);
      return IIopDefine.IIOP_EXCEPTION;
    }
    catch (Exception m_Exception) {
      CFunction.writeLog("setDebugNo In IIopEvent Error #2 ,", m_Exception);
      return IIopDefine.IIOP_EXCEPTION;
    }

    return 1;
  }

  public int processEvent(ArrayList m_ArrayList) {
    try {
      return this.m_ProcessEvent.processEvent(m_ArrayList);
    }
    catch (java.rmi.RemoteException m_RemoteException) {
      CFunction.writeLog("processEvent In IIopEvent Error #1 ,",
                         m_RemoteException);
      return IIopDefine.IIOP_EXCEPTION;
    }
    catch (Exception m_Exception) {
      CFunction.writeLog("processEvent In IIopEvent Error #2 ,", m_Exception);
      return IIopDefine.IIOP_EXCEPTION;
    }

  }

}