iiopsenddata.java

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

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

package collector.iiop;

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

import collector.common.*; //import pbs.sessionbean.front.*;
import pbs.service.struct.*; //import pbs.sessionbean.front.*;//import pbs.sessionbean.front.*;//import pbs.sessionbean.front.*;//import pbs.sessionbean.front.*;//import pbs.sessionbean.front.*;
//import pbs.sessionbean.front.*;
import pbs.sessionbean.ejb.*;

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

  private ProcessFrontData m_ProcessFrontData = null;
  private ProcessFrontDataHome m_ProcessFrontDataHome = 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 IIopSendData() {
    //    this.m_ProcessFrontData = 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_ProcessFrontDataHome = (ProcessFrontDataHome) PortableRemoteObject.
          narrow(m_Object, ProcessFrontDataHome.class);

      //CollectorDefine.SystemPrintln ("START TO CREATE ");
      //this.m_ProcessFrontData = null;
      //this.m_ProcessFrontData = m_ProcessFrontDataHome.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 initConnect(int m_debug_no) {

    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_ProcessFrontDataHome = (ProcessFrontDataHome) PortableRemoteObject.
          narrow(m_Object, ProcessFrontDataHome.class);

      //CollectorDefine.SystemPrintln ("START TO CREATE ");
      //this.m_ProcessFrontData = null;
      //this.m_ProcessFrontData = m_ProcessFrontDataHome.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(int m_debug_no) {
    try {
      //CollectorDefine.SystemPrintln ("START TO LOOKUP 。。。");
      m_Object = m_Context.lookup(m_JndiName);
      m_ProcessFrontDataHome = (ProcessFrontDataHome) PortableRemoteObject.
          narrow(m_Object, ProcessFrontDataHome.class);

      //CollectorDefine.SystemPrintln ("START TO CREATE ");
      //this.m_ProcessFrontData = null;
      //this.m_ProcessFrontData = m_ProcessFrontDataHome.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 ProcessFrontData connect() throws CreateException, RemoteException {
    this.m_ProcessFrontData = m_ProcessFrontDataHome.create();
    return m_ProcessFrontData;
  }

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

    return 1;
  }

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

    return 1;
  }

  public int processData(SendDataClass m_SendDataClass) {
    try {
      return this.m_ProcessFrontData.processData(m_SendDataClass);
    }
    catch (java.rmi.RemoteException m_RemoteException) {
      CFunction.writeLog("processData In IIopSendData Error #1",
                         m_RemoteException);
      return IIopDefine.IIOP_EXCEPTION;
    }
    catch (Exception m_Exception) {
      CFunction.writeLog("processData In IIopSendData Error #2", m_Exception);
      return IIopDefine.IIOP_EXCEPTION;
    }

  }
}