public class org.apache.activemq.store.kahadb.KahaDBTransactionStore extends java.lang.Object implements org.apache.activemq.store.TransactionStore
{
static final org.slf4j.Logger LOG;
java.util.concurrent.ConcurrentMap inflightTransactions;
private final org.apache.activemq.store.kahadb.KahaDBStore theStore;
public void <init>(org.apache.activemq.store.kahadb.KahaDBStore)
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBStore v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.store.kahadb.KahaDBStore;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions> = v;
v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore> = v;
return;
}
private org.apache.activemq.wireformat.WireFormat wireFormat()
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.wireformat.WireFormat wireFormat>;
return v;
}
public org.apache.activemq.store.MessageStore proxy(org.apache.activemq.store.MessageStore)
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$1 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.store.MessageStore;
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$1;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$1: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.store.MessageStore)>(v, v);
return v;
}
public org.apache.activemq.store.TopicMessageStore proxy(org.apache.activemq.store.TopicMessageStore)
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.store.TopicMessageStore;
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.store.TopicMessageStore)>(v, v);
return v;
}
public void prepare(org.apache.activemq.command.TransactionId) throws java.io.IOException
{
org.apache.activemq.store.kahadb.data.KahaTransactionInfo v;
org.apache.activemq.store.kahadb.data.KahaPrepareCommand v, v;
java.util.concurrent.ConcurrentMap v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBStore v, v, v;
java.lang.Object v, v, v;
org.apache.activemq.command.TransactionId v;
boolean v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v = specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.data.KahaTransactionInfo getTransactionInfo(org.apache.activemq.command.TransactionId)>(v);
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = new org.apache.activemq.store.kahadb.data.KahaPrepareCommand;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaPrepareCommand: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaPrepareCommand: java.lang.Object setTransactionInfo(org.apache.activemq.store.kahadb.data.KahaTransactionInfo)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand,boolean,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware,java.lang.Runnable)>(v, 1, null, null);
goto label;
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = new org.apache.activemq.store.kahadb.data.KahaPrepareCommand;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaPrepareCommand: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaPrepareCommand: java.lang.Object setTransactionInfo(org.apache.activemq.store.kahadb.data.KahaTransactionInfo)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand,boolean,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware,java.lang.Runnable)>(v, 1, null, null);
label:
return;
}
public org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)
{
java.lang.Throwable v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
java.util.concurrent.ConcurrentMap v, v, v, v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
java.lang.Object v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: java.lang.Object;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
entermonitor v;
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore)>(v);
v = v;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
catch java.lang.Throwable from label to label with label;
}
public void commit(org.apache.activemq.command.TransactionId, boolean, java.lang.Runnable, java.lang.Runnable) throws java.io.IOException
{
java.lang.Runnable v, v;
boolean v, v, v, v, v, v, v, v;
org.apache.activemq.broker.BrokerService v, v;
org.apache.activemq.store.kahadb.data.KahaTransactionInfo v, v;
java.util.concurrent.CancellationException v;
org.apache.activemq.store.kahadb.data.KahaCommitCommand v, v;
java.util.List v;
org.apache.activemq.store.kahadb.KahaDBStore v, v, v, v, v, v, v;
java.util.concurrent.ConcurrentMap v;
java.lang.String v, v;
org.apache.activemq.command.TransactionId v;
org.slf4j.Logger v;
java.util.Iterator v;
java.io.IOException v, v;
java.util.concurrent.ExecutionException v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
java.lang.InterruptedException v;
java.lang.Object v, v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v := @parameter: boolean;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Runnable;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v == 0 goto label;
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: java.util.List commit()>();
v = 0;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = new java.io.IOException;
v = virtualinvoke v.<java.lang.InterruptedException: java.lang.String getMessage()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void handleIOException(java.io.IOException)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = new java.io.IOException;
v = virtualinvoke v.<java.util.concurrent.ExecutionException: java.lang.String getMessage()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void handleIOException(java.io.IOException)>(v);
goto label;
label:
v := @caughtexception;
label:
v = interfaceinvoke v.<java.util.concurrent.Future: boolean isCancelled()>();
if v != 0 goto label;
v = 1;
goto label;
label:
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
if v == 0 goto label;
v = specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.data.KahaTransactionInfo getTransactionInfo(org.apache.activemq.command.TransactionId)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = new org.apache.activemq.store.kahadb.data.KahaCommitCommand;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaCommitCommand: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaCommitCommand: java.lang.Object setTransactionInfo(org.apache.activemq.store.kahadb.data.KahaTransactionInfo)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableJournalDiskSyncs()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand,boolean,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware,java.lang.Runnable)>(v, v, null, null);
goto label;
label:
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
goto label;
label:
v = specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.data.KahaTransactionInfo getTransactionInfo(org.apache.activemq.command.TransactionId)>(v);
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = new org.apache.activemq.store.kahadb.data.KahaCommitCommand;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaCommitCommand: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaCommitCommand: java.lang.Object setTransactionInfo(org.apache.activemq.store.kahadb.data.KahaTransactionInfo)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableJournalDiskSyncs()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand,boolean,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware,java.lang.Runnable)>(v, v, null, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: void forgetRecoveredAcks(org.apache.activemq.command.TransactionId,boolean)>(v, 0);
goto label;
label:
v = <org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Null transaction passed on commit");
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
catch java.util.concurrent.CancellationException from label to label with label;
}
public void rollback(org.apache.activemq.command.TransactionId) throws java.io.IOException
{
org.apache.activemq.store.kahadb.data.KahaTransactionInfo v;
java.util.concurrent.ConcurrentMap v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBStore v, v, v;
java.lang.Object v;
org.apache.activemq.store.kahadb.data.KahaRollbackCommand v;
org.apache.activemq.command.TransactionId v;
boolean v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
v = specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.data.KahaTransactionInfo getTransactionInfo(org.apache.activemq.command.TransactionId)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = new org.apache.activemq.store.kahadb.data.KahaRollbackCommand;
specialinvoke v.<org.apache.activemq.store.kahadb.data.KahaRollbackCommand: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRollbackCommand: java.lang.Object setTransactionInfo(org.apache.activemq.store.kahadb.data.KahaTransactionInfo)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isEnableJournalDiskSyncs()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand,boolean,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware,java.lang.Runnable)>(v, v, null, null);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: void forgetRecoveredAcks(org.apache.activemq.command.TransactionId,boolean)>(v, 1);
goto label;
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: java.util.concurrent.ConcurrentMap inflightTransactions>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
label:
return;
}
protected void forgetRecoveredAcks(org.apache.activemq.command.TransactionId, boolean) throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.TransactionId v;
boolean v, v;
java.util.ArrayList v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.command.XATransactionId: java.util.ArrayList getPreparedAcks()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void forgetRecoveredAcks(java.util.ArrayList,boolean)>(v, v);
label:
return;
}
public void start() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
return;
}
public void stop() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
return;
}
public synchronized void recover(org.apache.activemq.store.TransactionRecoveryListener) throws java.io.IOException
{
org.apache.activemq.store.kahadb.JournalCommand v, v, v;
org.apache.activemq.protobuf.Buffer v, v;
org.apache.activemq.store.kahadb.MessageDatabase$Operation v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.store.TransactionRecoveryListener v;
boolean v, v;
org.apache.activemq.wireformat.WireFormat v, v;
java.util.Set v;
org.apache.activemq.store.kahadb.KahaDBStore v, v;
java.io.DataInputStream v, v;
org.apache.activemq.command.MessageAck[] v;
java.util.ArrayList v, v;
java.util.LinkedHashMap v;
int v, v;
java.lang.String v;
java.util.Iterator v, v;
org.apache.activemq.command.Message[] v;
org.apache.activemq.protobuf.BufferInputStream v, v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
java.lang.Class v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.store.TransactionRecoveryListener;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore: java.util.LinkedHashMap preparedTransactions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v != class "Lorg/apache/activemq/store/kahadb/MessageDatabase$AddOperation;" goto label;
v = specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.wireformat.WireFormat wireFormat()>();
v = new java.io.DataInputStream;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.MessageDatabase$AddOperation: org.apache.activemq.store.kahadb.JournalCommand getCommand()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaAddMessageCommand: org.apache.activemq.protobuf.Buffer getMessage()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.Buffer: org.apache.activemq.protobuf.BufferInputStream newInput()>();
specialinvoke v.<java.io.DataInputStream: void <init>(java.io.InputStream)>(v);
v = interfaceinvoke v.<org.apache.activemq.wireformat.WireFormat: java.lang.Object unmarshal(java.io.DataInput)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.store.kahadb.MessageDatabase$RemoveOperation: org.apache.activemq.store.kahadb.JournalCommand getCommand()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: org.apache.activemq.protobuf.Buffer getAck()>();
v = specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.wireformat.WireFormat wireFormat()>();
v = new java.io.DataInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.Buffer: org.apache.activemq.protobuf.BufferInputStream newInput()>();
specialinvoke v.<java.io.DataInputStream: void <init>(java.io.InputStream)>(v);
v = interfaceinvoke v.<org.apache.activemq.wireformat.WireFormat: java.lang.Object unmarshal(java.io.DataInput)>(v);
v = new org.apache.activemq.command.ConsumerId;
specialinvoke v.<org.apache.activemq.command.ConsumerId: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.MessageDatabase$RemoveOperation: org.apache.activemq.store.kahadb.JournalCommand getCommand()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand: java.lang.String getSubscriptionKey()>();
virtualinvoke v.<org.apache.activemq.command.ConsumerId: void setConnectionId(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.command.MessageAck: void setConsumerId(org.apache.activemq.command.ConsumerId)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (org.apache.activemq.command.Message)[v];
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (org.apache.activemq.command.MessageAck)[v];
virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.activemq.command.XATransactionId: void setPreparedAcks(java.util.ArrayList)>(v);
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: void trackRecoveredAcks(java.util.ArrayList)>(v);
interfaceinvoke v.<org.apache.activemq.store.TransactionRecoveryListener: void recover(org.apache.activemq.command.XATransactionId,org.apache.activemq.command.Message[],org.apache.activemq.command.MessageAck[])>(v, v, v);
goto label;
label:
return;
}
void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.store.MessageStore, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$3 v;
org.apache.activemq.command.TransactionId v, v, v;
boolean v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.store.MessageStore;
v := @parameter: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$3;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,org.apache.activemq.store.MessageStore)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void add(org.apache.activemq.store.kahadb.KahaDBTransactionStore$AddMessageCommand)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
label:
return;
}
org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.store.MessageStore, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v, v, v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.TransactionId v, v, v;
boolean v, v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$4 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.store.MessageStore;
v := @parameter: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
v = <org.apache.activemq.store.AbstractMessageStore: org.apache.activemq.store.ListenableFuture FUTURE>;
return v;
label:
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$4;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$4: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,org.apache.activemq.store.MessageStore)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void add(org.apache.activemq.store.kahadb.KahaDBTransactionStore$AddMessageCommand)>(v);
v = <org.apache.activemq.store.AbstractMessageStore: org.apache.activemq.store.ListenableFuture FUTURE>;
return v;
label:
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
return v;
}
org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.store.MessageStore, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v, v, v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.TransactionId v, v, v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$5 v;
boolean v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.store.MessageStore;
v := @parameter: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
v = <org.apache.activemq.store.AbstractMessageStore: org.apache.activemq.store.ListenableFuture FUTURE>;
return v;
label:
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$5;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$5: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,org.apache.activemq.store.MessageStore)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void add(org.apache.activemq.store.kahadb.KahaDBTransactionStore$AddMessageCommand)>(v);
v = <org.apache.activemq.store.AbstractMessageStore: org.apache.activemq.store.ListenableFuture FUTURE>;
return v;
label:
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
return v;
}
final void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.store.MessageStore, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$6 v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.TransactionId v, v;
boolean v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.store.MessageStore;
v := @parameter: org.apache.activemq.command.MessageAck;
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: boolean isInTransaction()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$6;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$6: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck,org.apache.activemq.store.MessageStore)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void add(org.apache.activemq.store.kahadb.KahaDBTransactionStore$RemoveMessageCommand)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
label:
return;
}
final void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.store.MessageStore, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$7 v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.TransactionId v, v;
boolean v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.store.MessageStore;
v := @parameter: org.apache.activemq.command.MessageAck;
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: boolean isInTransaction()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$7;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$7: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck,org.apache.activemq.store.MessageStore)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void add(org.apache.activemq.store.kahadb.KahaDBTransactionStore$RemoveMessageCommand)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
label:
return;
}
final void acknowledge(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.store.TopicMessageStore, java.lang.String, java.lang.String, org.apache.activemq.command.MessageId, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$8 v;
org.apache.activemq.store.kahadb.KahaDBStore v;
java.lang.String v, v;
org.apache.activemq.command.TransactionId v, v;
boolean v, v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.store.TopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.activemq.command.MessageId;
v := @parameter: org.apache.activemq.command.MessageAck;
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: boolean isInTransaction()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.command.TransactionId: boolean isXATransaction()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: boolean isConcurrentStoreAndDispatchTransactions()>();
if v != 0 goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void acknowledge(org.apache.activemq.broker.ConnectionContext,java.lang.String,java.lang.String,org.apache.activemq.command.MessageId,org.apache.activemq.command.MessageAck)>(v, v, v, v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx getTx(java.lang.Object)>(v);
v = new org.apache.activemq.store.kahadb.KahaDBTransactionStore$8;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$8: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck,org.apache.activemq.store.TopicMessageStore,java.lang.String,java.lang.String,org.apache.activemq.command.MessageId)>(v, v, v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$Tx: void add(org.apache.activemq.store.kahadb.KahaDBTransactionStore$RemoveMessageCommand)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void acknowledge(org.apache.activemq.broker.ConnectionContext,java.lang.String,java.lang.String,org.apache.activemq.command.MessageId,org.apache.activemq.command.MessageAck)>(v, v, v, v, v);
label:
return;
}
private org.apache.activemq.store.kahadb.data.KahaTransactionInfo getTransactionInfo(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.store.kahadb.data.KahaTransactionInfo v;
org.apache.activemq.store.TransactionIdTransformer v;
org.apache.activemq.store.kahadb.KahaDBStore v;
org.apache.activemq.command.TransactionId v, v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.kahadb.KahaDBStore theStore>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.TransactionIdTransformer getTransactionIdTransformer()>();
v = interfaceinvoke v.<org.apache.activemq.store.TransactionIdTransformer: org.apache.activemq.command.TransactionId transform(org.apache.activemq.command.TransactionId)>(v);
v = staticinvoke <org.apache.activemq.store.kahadb.TransactionIdConversion: org.apache.activemq.store.kahadb.data.KahaTransactionInfo convert(org.apache.activemq.command.TransactionId)>(v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/store/kahadb/KahaDBTransactionStore;");
<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.slf4j.Logger LOG> = v;
return;
}
}