- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.unpackFrom()
方法的一些代码示例,展示了XidImple.unpackFrom()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XidImple.unpackFrom()
方法的具体详情如下:
包路径:com.arjuna.ats.jta.xa.XidImple
类名称:XidImple
方法名:unpackFrom
暂无
代码示例来源:origin: org.jboss.narayana.jta/jta
public static final Xid unpack(InputObjectState os) throws IOException {
if (os.unpackBoolean()) {
XidImple x = new XidImple();
x.unpackFrom(os);
return x;
} else {
try {
byte[] b = os.unpackBytes();
ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream o = new ObjectInputStream(s);
Xid x = (Xid) o.readObject();
return x;
} catch (Exception e) {
jtaLogger.logger.debug("Can't unpack input object state " + os, e);
IOException ioException = new IOException(e.toString());
ioException.initCause(e);
throw ioException;
}
}
}
代码示例来源:origin: org.jboss.jbossts/jbossjta
public static final Xid unpack(InputObjectState os) throws IOException {
if (os.unpackBoolean()) {
XidImple x = new XidImple();
x.unpackFrom(os);
return x;
} else {
try {
byte[] b = os.unpackBytes();
ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream o = new ObjectInputStream(s);
Xid x = (Xid) o.readObject();
return x;
} catch (Exception e) {
IOException ioException = new IOException(e.toString());
ioException.initCause(e);
throw ioException;
}
}
}
代码示例来源:origin: jbosstm/narayana
public static final Xid unpack(InputObjectState os) throws IOException {
if (os.unpackBoolean()) {
XidImple x = new XidImple();
x.unpackFrom(os);
return x;
} else {
try {
byte[] b = os.unpackBytes();
ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream o = new ObjectInputStream(s);
Xid x = (Xid) o.readObject();
return x;
} catch (Exception e) {
jtaLogger.logger.debug("Can't unpack input object state " + os, e);
IOException ioException = new IOException(e.toString());
ioException.initCause(e);
throw ioException;
}
}
}
代码示例来源:origin: org.jboss.narayana.jts/narayana-jts-idlj
public static final Xid unpack(InputObjectState os) throws IOException {
if (os.unpackBoolean()) {
XidImple x = new XidImple();
x.unpackFrom(os);
return x;
} else {
try {
byte[] b = os.unpackBytes();
ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream o = new ObjectInputStream(s);
Xid x = (Xid) o.readObject();
return x;
} catch (Exception e) {
jtaLogger.logger.debug("Can't unpack input object state " + os, e);
IOException ioException = new IOException(e.toString());
ioException.initCause(e);
throw ioException;
}
}
}
代码示例来源:origin: org.jboss.jbossts.jta/narayana-jta
public static final Xid unpack(InputObjectState os) throws IOException {
if (os.unpackBoolean()) {
XidImple x = new XidImple();
x.unpackFrom(os);
return x;
} else {
try {
byte[] b = os.unpackBytes();
ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream o = new ObjectInputStream(s);
Xid x = (Xid) o.readObject();
return x;
} catch (Exception e) {
IOException ioException = new IOException(e.toString());
ioException.initCause(e);
throw ioException;
}
}
}
代码示例来源:origin: jbosstm/narayana
public static final Xid unpack(InputObjectState os) throws IOException {
if (os.unpackBoolean()) {
XidImple x = new XidImple();
x.unpackFrom(os);
return x;
} else {
try {
byte[] b = os.unpackBytes();
ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream o = new ObjectInputStream(s);
Xid x = (Xid) o.readObject();
return x;
} catch (Exception e) {
jtaLogger.logger.debug("Can't unpack input object state " + os, e);
IOException ioException = new IOException(e.toString());
ioException.initCause(e);
throw ioException;
}
}
}
代码示例来源:origin: org.jboss.narayana.jts/narayana-jts-idlj
protected HeaderState unpackHeader(InputObjectState os) throws IOException {
wasInvoked = true;
if (os.unpackBoolean())
new XidImple().unpackFrom(os);
return super.unpackHeader(os);
}
代码示例来源:origin: jboss.jbossts/jbossjts
public boolean restore_state (InputObjectState os, int ot)
{
try
{
_theXid = null;
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
_theXid.unpackFrom(os);
}
return super.restore_state(os, ot);
}
catch (IOException ex)
{
ex.printStackTrace();
}
return false;
}
代码示例来源:origin: jboss.jbossts/jbossjts
public boolean restore_state (InputObjectState os, int t)
{
try
{
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: org.jboss.narayana.jts/narayana-jts-idlj
public boolean restore_state (InputObjectState os, int ot)
{
try
{
_theXid = null;
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
_theXid.unpackFrom(os);
}
return super.restore_state(os, ot);
}
catch (IOException ex)
{
jtaxLogger.i18NLogger.warn_cant_restore_state(os, ot, ex);
}
return false;
}
代码示例来源:origin: org.jboss.jbossts/jbossjta
public boolean restore_state (InputObjectState os, int t)
{
_theXid = null;
try
{
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: jbosstm/narayana
public boolean restore_state (InputObjectState os, int t)
{
_theXid = null;
try
{
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: org.jboss.narayana.jta/jta
public boolean restore_state (InputObjectState os, int t)
{
_theXid = null;
try
{
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: org.jboss.narayana.jts/narayana-jts-idlj
public boolean restore_state (InputObjectState os, int t)
{
_theXid = null;
try
{
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: org.jboss.jbossts.jta/narayana-jta
public boolean restore_state (InputObjectState os, int t)
{
_theXid = null;
try
{
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: jbosstm/narayana
public boolean restore_state (InputObjectState os, int t)
{
_theXid = null;
try
{
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid)
{
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
}
catch (IOException ex)
{
return false;
}
return super.restore_state(os, t);
}
代码示例来源:origin: org.jboss.jbossts/jbossjta
public SubordinateAtomicAction(Uid actId, boolean peekXidOnly) throws ObjectStoreException, IOException {
super(actId);
if (peekXidOnly) {
InputObjectState os = StoreManager.getParticipantStore().read_committed(objectUid, type());
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid) {
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
} else {
_activated = activate();
}
}
代码示例来源:origin: org.jboss.jbossts.jta/narayana-jta
/**
* Recovery SAA. If the record is removed and peekXidOnly is true then the Xid will be null.
*
* @param actId
* @param peekXidOnly
* @throws ObjectStoreException
* @throws IOException
*/
public SubordinateAtomicAction(Uid actId, boolean peekXidOnly) throws ObjectStoreException, IOException {
super(actId);
if (peekXidOnly) {
InputObjectState os = StoreManager.getParticipantStore().read_committed(objectUid, type());
if (os == null) {
// This will have been logged by the ObjectStore during ShadowingStore::read_state as an INFO if there was no content
return;
}
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid) {
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
} else {
_activated = activate();
}
}
代码示例来源:origin: jbosstm/narayana
/**
* Recovery SAA. If the record is removed and peekXidOnly is true then the Xid will be null.
*
* @param actId
* @param peekXidOnly
* @throws ObjectStoreException
* @throws IOException
*/
public SubordinateAtomicAction(Uid actId, boolean peekXidOnly) throws ObjectStoreException, IOException {
super(actId);
if (peekXidOnly) {
InputObjectState os = StoreManager.getParticipantStore().read_committed(objectUid, type());
if (os == null) {
// This will have been logged by the ObjectStore during ShadowingStore::read_state as an INFO if there was no content
return;
}
unpackHeader(os, new Header());
boolean haveXid = os.unpackBoolean();
if (haveXid) {
_theXid = new XidImple();
((XidImple) _theXid).unpackFrom(os);
_parentNodeName = os.unpackString();
}
} else {
_activated = activate();
}
}
代码示例来源: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));
}
}
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.getXID()方法的一些代码示例,展示了XidImple.getXID()的具体用法。这些代码示例主要来源于Gith
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.getTransactionUid()方法的一些代码示例,展示了XidImple.getTransactionUid(
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.unpackFrom()方法的一些代码示例,展示了XidImple.unpackFrom()的具体用法。这些代码示例主
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.getFormatId()方法的一些代码示例,展示了XidImple.getFormatId()的具体用法。这些代码示
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.getHash()方法的一些代码示例,展示了XidImple.getHash()的具体用法。这些代码示例主要来源于Gi
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.getBranchQualifier()方法的一些代码示例,展示了XidImple.getBranchQualifie
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.getGlobalTransactionId()方法的一些代码示例,展示了XidImple.getGlobalTran
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.copy()方法的一些代码示例,展示了XidImple.copy()的具体用法。这些代码示例主要来源于Github/S
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.packInto()方法的一些代码示例,展示了XidImple.packInto()的具体用法。这些代码示例主要来源于
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.()方法的一些代码示例,展示了XidImple.()的具体用法。这些代码示例主要来源于Github/Stackover
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.generateHash()方法的一些代码示例,展示了XidImple.generateHash()的具体用法。这些代
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.isSameTransaction()方法的一些代码示例,展示了XidImple.isSameTransaction(
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.pack()方法的一些代码示例,展示了XidImple.pack()的具体用法。这些代码示例主要来源于Github/S
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.unpack()方法的一些代码示例,展示了XidImple.unpack()的具体用法。这些代码示例主要来源于Gith
本文整理了Java中com.arjuna.ats.jta.xa.XidImple.equals()方法的一些代码示例,展示了XidImple.equals()的具体用法。这些代码示例主要来源于Gith
本文整理了Java中org.apache.geronimo.transaction.manager.XidImpl.()方法的一些代码示例,展示了XidImpl.()的具体用法。这些代码示例主要来源于
本文整理了Java中org.apache.geronimo.transaction.manager.XidImpl.hash()方法的一些代码示例,展示了XidImpl.hash()的具体用法。这些代
我是一名优秀的程序员,十分优秀!