java类org.omg.CORBA.portable.ResponseHandler的实例源码-面圈网

ServantLocatorPOA.java 文件源码项目：javify 阅读 20 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

ServantActivatorPOA.java 文件源码项目：javify 阅读 23 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

DynamicImpHandler.java 文件源码项目：javify 阅读 21 收藏 0 点赞 0 评论 0

/**
 * We cannot invoke properly without having parameter info.
 *
 * @throws BAD_OPERATION, always.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
{
  throw new BAD_OPERATION(servant + " is not an InvokeHandler.");
}

ServantLocatorPOA.java 文件源码项目：jvm-stm 阅读 23 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

ServantActivatorPOA.java 文件源码项目：jvm-stm 阅读 23 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

DynamicImpHandler.java 文件源码项目：jvm-stm 阅读 27 收藏 0 点赞 0 评论 0

/**
 * We cannot invoke properly without having parameter info.
 *
 * @throws BAD_OPERATION, always.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
{
  throw new BAD_OPERATION(servant + " is not an InvokeHandler.");
}

ServantLocatorPOA.java 文件源码项目：JamVM-PH 阅读 22 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

ServantActivatorPOA.java 文件源码项目：JamVM-PH 阅读 24 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

DynamicImpHandler.java 文件源码项目：JamVM-PH 阅读 24 收藏 0 点赞 0 评论 0

/**
 * We cannot invoke properly without having parameter info.
 *
 * @throws BAD_OPERATION, always.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
{
  throw new BAD_OPERATION(servant + " is not an InvokeHandler.");
}

ServantLocatorPOA.java 文件源码项目：classpath 阅读 24 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

ServantActivatorPOA.java 文件源码项目：classpath 阅读 26 收藏 0 点赞 0 评论 0

/**
 * Our implementation will not call this method. After setting your
 * manager to POA, it will call incarnate and etherialize directly.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  throw new NO_IMPLEMENT();
}

DynamicImpHandler.java 文件源码项目：classpath 阅读 23 收藏 0 点赞 0 评论 0

/**
 * We cannot invoke properly without having parameter info.
 *
 * @throws BAD_OPERATION, always.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
{
  throw new BAD_OPERATION(servant + " is not an InvokeHandler.");
}

ForwardedServant.java 文件源码项目：javify 阅读 22 收藏 0 点赞 0 评论 0

/**
 * Forward the call to the wrapped object.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  org.omg.CORBA.portable.InputStream in = null;
  org.omg.CORBA.portable.OutputStream out = null;
  try
    {
      try
        {
          out = ref._request(method, true);

          // Transfer request information.
          int b;
          while ((b = input.read()) >= 0)
            {
              out.write(b);
            }
          in = ref._invoke(out);

          // Read the returned data.
          out = handler.createReply();
          while ((b = in.read()) >= 0)
            {
              out.write(b);
            }
        }
      catch (IOException io_ex)
        {
          MARSHAL m = new MARSHAL();
          m.minor = Minor.Forwarding;
          m.initCause(io_ex);
          throw m;
        }
    }
  catch (ApplicationException ex)
    {
      in = ex.getInputStream();

      String _id = ex.getId();
      throw new MARSHAL(_id, 5101, CompletionStatus.COMPLETED_NO);
    }
  catch (RemarshalException remarsh)
    {
      _invoke(method, input, handler);
    }
  finally
    {
      ref._releaseReply(in);
    }
  return out;
}

ForwardedServant.java 文件源码项目：jvm-stm 阅读 28 收藏 0 点赞 0 评论 0

/**
 * Forward the call to the wrapped object.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  org.omg.CORBA.portable.InputStream in = null;
  org.omg.CORBA.portable.OutputStream out = null;
  try
    {
      try
        {
          out = ref._request(method, true);

          // Transfer request information.
          int b;
          while ((b = input.read()) >= 0)
            {
              out.write(b);
            }
          in = ref._invoke(out);

          // Read the returned data.
          out = handler.createReply();
          while ((b = in.read()) >= 0)
            {
              out.write(b);
            }
        }
      catch (IOException io_ex)
        {
          MARSHAL m = new MARSHAL();
          m.minor = Minor.Forwarding;
          m.initCause(io_ex);
          throw m;
        }
    }
  catch (ApplicationException ex)
    {
      in = ex.getInputStream();

      String _id = ex.getId();
      throw new MARSHAL(_id, 5101, CompletionStatus.COMPLETED_NO);
    }
  catch (RemarshalException remarsh)
    {
      _invoke(method, input, handler);
    }
  finally
    {
      ref._releaseReply(in);
    }
  return out;
}

ForwardedServant.java 文件源码项目：JamVM-PH 阅读 23 收藏 0 点赞 0 评论 0

/**
 * Forward the call to the wrapped object.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  org.omg.CORBA.portable.InputStream in = null;
  org.omg.CORBA.portable.OutputStream out = null;
  try
    {
      try
        {
          out = ref._request(method, true);

          // Transfer request information.
          int b;
          while ((b = input.read()) >= 0)
            {
              out.write(b);
            }
          in = ref._invoke(out);

          // Read the returned data.
          out = handler.createReply();
          while ((b = in.read()) >= 0)
            {
              out.write(b);
            }
        }
      catch (IOException io_ex)
        {
          MARSHAL m = new MARSHAL();
          m.minor = Minor.Forwarding;
          m.initCause(io_ex);
          throw m;
        }
    }
  catch (ApplicationException ex)
    {
      in = ex.getInputStream();

      String _id = ex.getId();
      throw new MARSHAL(_id, 5101, CompletionStatus.COMPLETED_NO);
    }
  catch (RemarshalException remarsh)
    {
      _invoke(method, input, handler);
    }
  finally
    {
      ref._releaseReply(in);
    }
  return out;
}

ForwardedServant.java 文件源码项目：classpath 阅读 23 收藏 0 点赞 0 评论 0

/**
 * Forward the call to the wrapped object.
 */
public OutputStream _invoke(String method, InputStream input,
                            ResponseHandler handler
                           )
                     throws SystemException
{
  org.omg.CORBA.portable.InputStream in = null;
  org.omg.CORBA.portable.OutputStream out = null;
  try
    {
      try
        {
          out = ref._request(method, true);

          // Transfer request information.
          int b;
          while ((b = input.read()) >= 0)
            {
              out.write(b);
            }
          in = ref._invoke(out);

          // Read the returned data.
          out = handler.createReply();
          while ((b = in.read()) >= 0)
            {
              out.write(b);
            }
        }
      catch (IOException io_ex)
        {
          MARSHAL m = new MARSHAL();
          m.minor = Minor.Forwarding;
          m.initCause(io_ex);
          throw m;
        }
    }
  catch (ApplicationException ex)
    {
      in = ex.getInputStream();

      String _id = ex.getId();
      throw new MARSHAL(_id, 5101, CompletionStatus.COMPLETED_NO);
    }
  catch (RemarshalException remarsh)
    {
      _invoke(method, input, handler);
    }
  finally
    {
      ref._releaseReply(in);
    }
  return out;
}