- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.objectweb.howl.log.xa.XACommittingTx.getLogKey()
方法的一些代码示例,展示了XACommittingTx.getLogKey()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XACommittingTx.getLogKey()
方法的具体详情如下:
包路径:org.objectweb.howl.log.xa.XACommittingTx
类名称:XACommittingTx
方法名:getLogKey
暂无
代码示例来源:origin: apache/felix
/**
* displays entries in the activeTx table.
* <p>useful for debug.
*/
public void activeTxDisplay()
{
for (int i=0; i < activeTx.length; ++i)
{
if (activeTx[i] == null) continue;
synchronized(activeTx)
{
XACommittingTx tx = activeTx[i];
byte[][] record = tx.getRecord();
System.out.println("activeTx[" + i + "] key=" + Long.toHexString(tx.getLogKey()) +
"\n Fields: " + record.length
);
for (int j = 0; j < record.length; ++j)
{
byte[] field = record[j];
System.out.println(" [" + j + "] len=" + field.length + ": " + new String(field));
}
}
}
}
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl
/**
* displays entries in the activeTx table.
* <p>useful for debug.
*/
public void activeTxDisplay()
{
for (int i=0; i < activeTx.length; ++i)
{
if (activeTx[i] == null) continue;
synchronized(activeTx)
{
XACommittingTx tx = activeTx[i];
byte[][] record = tx.getRecord();
System.out.println("activeTx[" + i + "] key=" + Long.toHexString(tx.getLogKey()) +
"\n Fields: " + record.length
);
for (int j = 0; j < record.length; ++j)
{
byte[] field = record[j];
System.out.println(" [" + j + "] len=" + field.length + ": " + new String(field));
}
}
}
}
代码示例来源:origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction
/**
* displays entries in the activeTx table.
* <p>useful for debug.
*/
public void activeTxDisplay()
{
for (int i=0; i < activeTx.length; ++i)
{
if (activeTx[i] == null) continue;
synchronized(activeTx)
{
XACommittingTx tx = activeTx[i];
byte[][] record = tx.getRecord();
System.out.println("activeTx[" + i + "] key=" + Long.toHexString(tx.getLogKey()) +
"\n Fields: " + record.length
);
for (int j = 0; j < record.length; ++j)
{
byte[] field = record[j];
System.out.println(" [" + j + "] len=" + field.length + ": " + new String(field));
}
}
}
}
代码示例来源:origin: org.ow2.jotm/jotm-core
TraceTm.recovery.debug("Wrote UniqueIDRecord; at:" + LogId.getLogKey() + " uuid0:" + uuid0 + " uuid1:" + uuid1);
代码示例来源:origin: org.kuali.jotm/jotm-core
TraceTm.recovery.debug("Wrote UniqueIDRecord; at:" + LogId.getLogKey() + " uuid0:" + uuid0 + " uuid1:" + uuid1);
代码示例来源:origin: apache/felix
public void close() throws IOException, InterruptedException
{
if (isClosed) return;
long newMark = Long.MAX_VALUE;
XACommittingTx tx = null;
// set new log mark at oldest activeTx entry
synchronized(activeTxLock)
{
for (int i=0; i < activeTx.length; ++i)
{
tx = activeTx[i];
if (tx == null) continue;
long key = tx.getLogKey();
if (key < newMark) newMark = key;
}
if (newMark < Long.MAX_VALUE)
{
try {
this.mark(newMark, true);
} catch (InvalidLogKeyException e) {
// will not happen
} catch (LogClosedException e) {
// will not happen
}
}
}
super.close();
}
代码示例来源:origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction
public void close() throws IOException, InterruptedException
{
if (isClosed) return;
long newMark = Long.MAX_VALUE;
XACommittingTx tx = null;
// set new log mark at oldest activeTx entry
synchronized(activeTxLock)
{
for (int i=0; i < activeTx.length; ++i)
{
tx = activeTx[i];
if (tx == null) continue;
long key = tx.getLogKey();
if (key < newMark) newMark = key;
}
if (newMark < Long.MAX_VALUE)
{
try {
this.mark(newMark, true);
} catch (InvalidLogKeyException e) {
// will not happen
} catch (LogClosedException e) {
// will not happen
}
}
}
super.close();
}
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl
public void close() throws IOException, InterruptedException
{
if (isClosed) return;
long newMark = Long.MAX_VALUE;
XACommittingTx tx = null;
// set new log mark at oldest activeTx entry
synchronized(activeTxLock)
{
for (int i=0; i < activeTx.length; ++i)
{
tx = activeTx[i];
if (tx == null) continue;
long key = tx.getLogKey();
if (key < newMark) newMark = key;
}
if (newMark < Long.MAX_VALUE)
{
try {
this.mark(newMark, true);
} catch (InvalidLogKeyException e) {
// will not happen
} catch (LogClosedException e) {
// will not happen
}
}
}
super.close();
}
代码示例来源:origin: apache/felix
lr.key = tx.getLogKey();
lr.tod = 0L;
lr.setTx(tx);
代码示例来源:origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction
lr.key = tx.getLogKey();
lr.tod = 0L;
lr.setTx(tx);
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl
lr.key = tx.getLogKey();
lr.tod = 0L;
lr.setTx(tx);
代码示例来源:origin: apache/felix
txKey = tx.getLogKey();
if (txKey > overflowFence)
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl
txKey = tx.getLogKey();
if (txKey > overflowFence)
代码示例来源:origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction
txKey = tx.getLogKey();
if (txKey > overflowFence)
本文整理了Java中org.objectweb.howl.log.xa.XACommittingTx.getLogKey()方法的一些代码示例,展示了XACommittingTx.getLogKey(
我是一名优秀的程序员,十分优秀!