org.omg.CORBA.INTERNAL类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(293)

本文整理了Java中org.omg.CORBA.INTERNAL类的一些代码示例，展示了INTERNAL类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。INTERNAL类的具体详情如下：
包路径：org.omg.CORBA.INTERNAL
类名称：INTERNAL

INTERNAL介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

try {
  byte[] oid = rootPoa.activate_object(new BindingIteratorImpl(rest));
  o = rootPoa.id_to_reference(oid);
} catch (Exception e) {
  IIOPLogger.ROOT_LOGGER.logInternalError(e);
  throw new INTERNAL(e.toString());

代码示例来源：origin: wildfly/wildfly

@Override
public final INTERNAL exceptionDestroingIterator(final String cause) {
  final INTERNAL result = new INTERNAL(String.format(getLoggingLocale(), exceptionDestroingIterator$str(), cause));
  final StackTraceElement[] st = result.getStackTrace();
  result.setStackTrace(Arrays.copyOfRange(st, 1, st.length));
  return result;
}
private static final String sslNotConfigured = "WFLYIIOP0103: IOR settings imply ssl connections usage, but secure connections have not been configured";

代码示例来源：origin: org.glassfish.main.transaction/jts

env = txOrb.create_environment();
} else {
  env = ORB.init().create_environment();
InputStream strm = any.create_input_stream();
String repId = ri.received_exception_id();
strm.read_string(); // read repId
int minorCode = strm.read_long(); // read minorCode
  CompletionStatus.from_int(strm.read_long());
if (repId.indexOf("UNKNOWN") != -1) { // user exception ?
if (minorCode == 1) { // read minorCode
  throw new TRANSACTION_ROLLEDBACK(0, completionStatus);
  any = this.codec.decode_value(svc.context_data, typeCode);
} catch (TypeMismatch e) {
  throw new INTERNAL(0, completionStatus);
} catch (FormatMismatch e) {
  throw new INTERNAL(0, completionStatus);

代码示例来源：origin: org.glassfish.main.transaction/jts

private void addOTSComponents(IORInfo iorInfo, OTSPolicy otsPolicy) {       
  short invPolicyValue = SHARED.value;
  short otsPolicyValue = ADAPTS.value;            
  if (otsPolicy != null) {
  otsPolicyValue = otsPolicy.value();
}
  
  Any otsAny = ORB.init().create_any();
  Any invAny = ORB.init().create_any();
  
  otsAny.insert_short(otsPolicyValue);
  invAny.insert_short(invPolicyValue);
  
  byte[] otsCompValue = null;
  byte[] invCompValue = null;                 
  try {
    otsCompValue = codec.encode_value(otsAny);
    invCompValue = codec.encode_value(invAny);
  } catch (org.omg.IOP.CodecPackage.InvalidTypeForEncoding e) {
    throw new INTERNAL("InvalidTypeForEncoding "+e.getMessage());
  }

  TaggedComponent otsComp = new TaggedComponent(TAG_OTS_POLICY.value,
                         otsCompValue);
  iorInfo.add_ior_component(otsComp);
  TaggedComponent invComp = new TaggedComponent(TAG_INV_POLICY.value,
                         invCompValue);
  iorInfo.add_ior_component(invComp);
}

代码示例来源：origin: org.apache.yoko/yoko-core

public static org.omg.CORBA.SystemException unmarshalSystemException(
    org.omg.CORBA.portable.InputStream in) {
  String id = in.read_string();
  int minor = in.read_ulong();
  org.omg.CORBA.CompletionStatus status = org.omg.CORBA.CompletionStatus
      .from_int(in.read_ulong());
    return new org.omg.CORBA.NO_PERMISSION(minor, status);
  } else if (id.equals("IDL:omg.org/CORBA/INTERNAL:1.0")) {
    return new org.omg.CORBA.INTERNAL(minor, status);
  } else if (id.equals("IDL:omg.org/CORBA/MARSHAL:1.0")) {
    String reason = MinorCodes.describeMarshal(minor);
    return new org.omg.CORBA.TRANSACTION_REQUIRED(minor, status);
  } else if (id.equals("IDL:omg.org/CORBA/TRANSACTION_ROLLEDBACK:1.0")) {
    return new org.omg.CORBA.TRANSACTION_ROLLEDBACK(minor, status);
  } else if (id.equals("IDL:omg.org/CORBA/INVALID_TRANSACTION:1.0")) {
    return new org.omg.CORBA.INVALID_TRANSACTION(minor, status);

代码示例来源：origin: org.jboss.openjdk-orb/openjdk-orb

/**
* Destroys this BindingIterator by disconnecting from the ORB
* @exception org.omg.CORBA.SystemException One of a fixed set of CORBA system exceptions.
*/
final public void Destroy()
{
  // Remove the object from the Active Object Map.
  try {
    byte[] objectId = biPOA.servant_to_id( this );
    if( objectId != null ) {
      biPOA.deactivate_object( objectId );
    }
  }
  catch( Exception e ) {
    throw new INTERNAL( "Exception in BindingIterator.Destroy " + e );
  }
}

代码示例来源：origin: org.glassfish.main.transaction/jts

throw new TRANSACTION_ROLLEDBACK(0, CompletionStatus.COMPLETED_YES);
  any = this.codec.decode_value(svc.context_data, typeCode);
} catch (TypeMismatch e) {
  throw new INTERNAL(0, CompletionStatus.COMPLETED_YES);
} catch (FormatMismatch e) {
  throw new INTERNAL(0, CompletionStatus.COMPLETED_YES);
  env = txOrb.create_environment();
} else {
  env = ORB.init().create_environment();

代码示例来源：origin: org.jboss.spec.javax.rmi/jboss-rmi-api_1.0_spec

public INTERNAL invokesetup(CompletionStatus cs, Throwable t)
{
  INTERNAL exc = new INTERNAL(INVOKESETUP, cs);
  if (t != null)
    exc.initCause(t);
  if (logger.isLoggable(Level.WARNING))
  {
    Object[] parameters = null;
    doLog(Level.WARNING, "POA.invokesetup", parameters, POASystemException.class, exc);
  }
  return exc;
}

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

if (ctx.type().kind().value() != TCKind._tk_null)
  if (ctx.type().kind().value() == TCKind._tk_string)
  org.omg.CORBA.Any threadData = ORBManager.getORB().orb().create_any();
  threadData.insert_string(ThreadUtil.getThreadId());
throw new org.omg.CORBA.INTERNAL();

代码示例来源：origin: org.jacorb/jacorb-services

} catch ( Exception e ){
  e.printStackTrace( System.out );
  throw new org.omg.CORBA.INTERNAL();
  throw new org.omg.CORBA.INVALID_TRANSACTION();
case LockSetFactoryImpl.ROLLBACK :
  throw new org.omg.CORBA.TRANSACTION_ROLLEDBACK();

代码示例来源：origin: org.apache.yoko/yoko-spec-corba

public static INTERNAL read(org.omg.CORBA.portable.InputStream in) {
  if (!id().equals(in.read_string()))
    throw new MARSHAL();
  INTERNAL val = new INTERNAL();
  val.minor = in.read_ulong();
  val.completed = CompletionStatus.from_int(in.read_ulong());
  return val;
}

代码示例来源：origin: org.jacorb/jacorb

if( ! type().equivalent( value.type() ))
   value.create_input_stream();
  length = is.read_long();
  throw new INTERNAL ("DynSequence.set_length, elementType null");

代码示例来源：origin: org.jacorb/jacorb-services

public SequenceFactoryImpl (org.omg.PortableServer.POA poa)
{
  this.poa = poa;
  try
  {
    poa.servant_to_reference (this);
  }
  catch (Exception e)
  {
    System.out.println ("Internal error: Can not activate factory");
    e.printStackTrace ();
    throw new org.omg.CORBA.INTERNAL ();
  }
}

代码示例来源：origin: org.jacorb/jacorb

/**
 *  create a new IdlWriter for the default JacORB IR
 *  which writes to a specific PrintStream
 *
 *  @param orb
 *  @param ps    a PrintStream
 *  @param logger
 */
public IdlWriter( ORB orb, PrintStream ps, Logger logger )
{
  printStream = ps;
  this.logger = logger;
  try
  {
    ir = org.omg.CORBA.RepositoryHelper.narrow(
         orb.resolve_initial_references("InterfaceRepository"));
    factory =
      org.omg.DynamicAny.DynAnyFactoryHelper.narrow (orb.resolve_initial_references ("DynAnyFactory"));
  }
  catch( org.omg.CORBA.ORBPackage.InvalidName e )
  {
    throw new INTERNAL(e.toString());
  }
  if( ir == null )
  {
    logger.error("No IR configured! Exiting..");
    System.exit(1);
  }
}

代码示例来源：origin: org.jacorb/jacorb-services

Any _maxConsumersDefaultAny = sORB.create_any();
_maxConsumersDefaultAny.insert_long( _maxConsumersDefault );
                Default.DEFAULT_MAX_NUMBER_SUPPLIERS);
Any _maxSuppliersDefaultAny = sORB.create_any();
_maxSuppliersDefaultAny.insert_long(_maxSuppliersDefault);
                Default.DEFAULT_MAX_QUEUE_LENGTH);
Any _maxQueueLengthAny = sORB.create_any();
_maxQueueLengthAny.insert_long(_maxQueueLength);
throw new INTERNAL ("Configuration exception" + ex);

代码示例来源：origin: org.glassfish.main.transaction/jts

poa.activate_object(this);
thisRef = TransactionFactoryHelper.
      narrow(poa.servant_to_reference(this));
try {
  namingContext = NamingContextHelper.narrow(
    Configuration.getORB().resolve_initial_references("NameService"/*#Frozen*/));
} catch (Exception exc) {
  _logger.log(Level.WARNING,"jts.orb_not_running");
 String msg = LogFormatter.getLocalizedMessage(_logger,
             "jts.create_transactionfactory_object_error");
 throw  new org.omg.CORBA.INTERNAL(msg);

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

private final void associateContext () throws SystemException
{
if (_piCurrent != null)
{
  try
  {
  int slotId = OTSManager.getLocalSlotId();
  if (slotId != -1)
  {
    org.omg.CORBA.Any localDataAny = ORBManager.getORB().orb().create_any();
    localDataAny.insert_string(ThreadUtil.getThreadId());
    _piCurrent.set_slot(slotId, localDataAny);
  }
  }
  catch (InvalidSlot is)
  {
  // Something very wrong
  throw new org.omg.CORBA.INTERNAL();
  }
}
}

代码示例来源：origin: org.glassfish.main.transaction/jts

new TRANSACTION_ROLLEDBACK(0, CompletionStatus.COMPLETED_NO);
throw exc;
      new TRANSACTION_ROLLEDBACK(
        0, CompletionStatus.COMPLETED_NO);
    ex2.initCause(exc);
    throw ex2;
  INTERNAL ex2 = new INTERNAL(MinorCode.NotRegistered,
                CompletionStatus.COMPLETED_NO);
  ex2.initCause(exc);
  throw ex2;
  INTERNAL ex2 = new INTERNAL(MinorCode.RecCoordCreateFailed,
                CompletionStatus.COMPLETED_NO);
  ex2.initCause(exc);
  throw ex2;

代码示例来源：origin: org.glassfish.main.transaction/jts

} else {
  TypeCode typeCode = txOrb.get_primitive_tc(TCKind.tk_short);
  Any any = null;
  try {
    any = this.codec.decode_value(otsComp.component_data, typeCode);
  } catch (TypeMismatch e) {
    throw new INTERNAL();
  } catch (FormatMismatch e) {
    throw new INTERNAL();
Any any = txOrb.create_any();
PropagationContextHelper.insert(any, hctx.value);
byte[] ctxData = null;
  ctxData = this.codec.encode_value(any);
} catch (InvalidTypeForEncoding e) {
  throw new INTERNAL();

代码示例来源：origin: org.jacorb/jacorb

namedValue.value().write_value(out);
    throw new INTERNAL("should not happen");
    any.read_value (e.getInputStream (), typeCode);
    env.exception (new org.omg.CORBA.UnknownUserException (any));
    break;
    e.getInputStream ().read_string (),
    0,
    CompletionStatus.COMPLETED_YES

内容来源于网络，如有侵权，请联系作者删除！

Internal

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com