gpt4 book ai didi

com.arjuna.ats.jta.xa.XidImple.unpack()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-24 23:05:05 26 4
gpt4 key购买 nike

本文整理了Java中com.arjuna.ats.jta.xa.XidImple.unpack()方法的一些代码示例,展示了XidImple.unpack()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XidImple.unpack()方法的具体详情如下:
包路径:com.arjuna.ats.jta.xa.XidImple
类名称:XidImple
方法名:unpack

XidImple.unpack介绍

暂无

代码示例

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

public boolean restoreState(InputObjectState os) {
  InputObjectState copy = new InputObjectState(os);
  try {
    heuristic = copy.unpackInt();
    committed = copy.unpackBoolean();
    xidImple = new XidImple(XidImple.unpack(copy));
    return super.restoreState(os);
  } catch (IOException e) {
    return false;
  }
}

代码示例来源:origin: jbosstm/narayana

@Test
  public void testPackUnpack () throws Exception
  {
    XidImple xid1 = new XidImple(new Uid());
    OutputObjectState os = new OutputObjectState();
    
    assertTrue(xid1.packInto(os));
    
    InputObjectState is = new InputObjectState(os);
    
    XidImple xid2 = new XidImple();
    
    assertTrue(xid2.unpackFrom(is));
    
    assertTrue(xid1.equals(xid2));
    
    os = new OutputObjectState();
    
    XidImple.pack(os, xid1);
    
    is = new InputObjectState(os);
    
    xid2 = (XidImple) XidImple.unpack(is);
    
    assertTrue(xid1.equals(xid2));
  }
}

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

tsLogger.logger.trace("unpack: " + commitMarkableJndiName);
xid = XidImple.unpack(os);
if (tsLogger.logger.isTraceEnabled()) {
  tsLogger.logger.trace("unpack: " + xid);

代码示例来源:origin: jbosstm/narayana

tsLogger.logger.trace("unpack: " + commitMarkableJndiName);
xid = XidImple.unpack(os);
if (tsLogger.logger.isTraceEnabled()) {
  tsLogger.logger.trace("unpack: " + xid);

代码示例来源:origin: jbosstm/narayana

tsLogger.logger.trace("unpack: " + commitMarkableJndiName);
xid = XidImple.unpack(os);
if (tsLogger.logger.isTraceEnabled()) {
  tsLogger.logger.trace("unpack: " + xid);

代码示例来源:origin: org.jboss.narayana.jta/jta

tsLogger.logger.trace("unpack: " + commitMarkableJndiName);
xid = XidImple.unpack(os);
if (tsLogger.logger.isTraceEnabled()) {
  tsLogger.logger.trace("unpack: " + xid);

代码示例来源:origin: org.jboss.jbossts.jta/narayana-jta

tsLogger.logger.trace("unpack: " + commitMarkableJndiName);
xid = XidImple.unpack(os);
if (tsLogger.logger.isTraceEnabled()) {
  tsLogger.logger.trace("unpack: " + xid);

代码示例来源:origin: org.jboss.narayana.jta/jta

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

代码示例来源:origin: jbosstm/narayana

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

代码示例来源:origin: jbosstm/narayana

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

代码示例来源:origin: jboss.jbossts/jbossjts

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

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

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

代码示例来源:origin: org.jboss.jbossts.jta/narayana-jta

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

代码示例来源:origin: org.jboss.jbossts/jbossjta

throws IOException
XidImple.unpack(is) ;
final int recoveryType = is.unpackInt() ;
switch(recoveryType)

代码示例来源:origin: org.jboss.jbossts.jta/narayana-jta

public RecoverConnectableAtomicAction(String type, Uid rcvUid, InputObjectState os)
    throws ObjectStoreException, IOException {
  super(rcvUid);
  this.recoveringAs = type;
  
  // Unpack BasicAction::save_state preamble
  Header hdr = new Header();
  unpackHeader(os, hdr);
  os.unpackBoolean(); // FYI pastFirstParticipant
  // Take a look at the first record type
  int record_type = os.unpackInt();
  if (record_type == RecordType.COMMITMARKABLERESOURCE) {
    // Its one we are interested in
    jndiName = os.unpackString();
    xid = XidImple.unpack(os);
    hasCompleted = os.unpackBoolean();
  }
}

代码示例来源:origin: org.jboss.jbossts/jbossjta

_committed = os.unpackBoolean();
_tranID = XidImple.unpack(os);

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

public RecoverConnectableAtomicAction(String type, Uid rcvUid, InputObjectState os)
    throws ObjectStoreException, IOException {
  super(rcvUid);
  this.recoveringAs = type;
  
  // Unpack BasicAction::save_state preamble
  Header hdr = new Header();
  unpackHeader(os, hdr);
  os.unpackBoolean(); // FYI pastFirstParticipant
  // Take a look at the first record type
  int record_type = os.unpackInt();
  if (record_type == RecordType.COMMITMARKABLERESOURCE) {
    // Its one we are interested in
    jndiName = os.unpackString();
    xid = XidImple.unpack(os);
    hasCompleted = os.unpackBoolean();
    if (hasCompleted) {
      wasCommitted = os.unpackBoolean();
    }
  }
}

代码示例来源:origin: jbosstm/narayana

public RecoverConnectableAtomicAction(String type, Uid rcvUid, InputObjectState os)
    throws ObjectStoreException, IOException {
  super(rcvUid);
  this.recoveringAs = type;
  
  // Unpack BasicAction::save_state preamble
  Header hdr = new Header();
  unpackHeader(os, hdr);
  os.unpackBoolean(); // FYI pastFirstParticipant
  // Take a look at the first record type
  int record_type = os.unpackInt();
  if (record_type == RecordType.COMMITMARKABLERESOURCE) {
    // Its one we are interested in
    jndiName = os.unpackString();
    xid = XidImple.unpack(os);
    hasCompleted = os.unpackBoolean();
    if (hasCompleted) {
      wasCommitted = os.unpackBoolean();
    }
  }
}

代码示例来源:origin: org.jboss.narayana.jta/jta

public RecoverConnectableAtomicAction(String type, Uid rcvUid, InputObjectState os)
    throws ObjectStoreException, IOException {
  super(rcvUid);
  this.recoveringAs = type;
  
  // Unpack BasicAction::save_state preamble
  Header hdr = new Header();
  unpackHeader(os, hdr);
  os.unpackBoolean(); // FYI pastFirstParticipant
  // Take a look at the first record type
  int record_type = os.unpackInt();
  if (record_type == RecordType.COMMITMARKABLERESOURCE) {
    // Its one we are interested in
    jndiName = os.unpackString();
    xid = XidImple.unpack(os);
    hasCompleted = os.unpackBoolean();
    if (hasCompleted) {
      wasCommitted = os.unpackBoolean();
    }
  }
}

代码示例来源:origin: jbosstm/narayana

public RecoverConnectableAtomicAction(String type, Uid rcvUid, InputObjectState os)
    throws ObjectStoreException, IOException {
  super(rcvUid);
  this.recoveringAs = type;
  
  // Unpack BasicAction::save_state preamble
  Header hdr = new Header();
  unpackHeader(os, hdr);
  os.unpackBoolean(); // FYI pastFirstParticipant
  // Take a look at the first record type
  int record_type = os.unpackInt();
  if (record_type == RecordType.COMMITMARKABLERESOURCE) {
    // Its one we are interested in
    jndiName = os.unpackString();
    xid = XidImple.unpack(os);
    hasCompleted = os.unpackBoolean();
    if (hasCompleted) {
      wasCommitted = os.unpackBoolean();
    }
  }
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com