class org.apache.activemq.store.kahadb.KahaDBTransactionStore$3 extends org.apache.activemq.store.kahadb.KahaDBTransactionStore$AddMessageCommand
{
final org.apache.activemq.command.Message val$message;
final org.apache.activemq.store.MessageStore val$destination;
final org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0;
void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, org.apache.activemq.store.MessageStore)
{
org.apache.activemq.store.MessageStore 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.KahaDBTransactionStore$3 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$3;
v := @parameter: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.store.MessageStore;
v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0> = v;
v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: org.apache.activemq.command.Message val$message> = v;
v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: org.apache.activemq.store.MessageStore val$destination> = v;
specialinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$AddMessageCommand: void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore,org.apache.activemq.broker.ConnectionContext)>(v, v);
return;
}
public org.apache.activemq.command.Message getMessage()
{
org.apache.activemq.command.Message v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$3 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$3;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: org.apache.activemq.command.Message val$message>;
return v;
}
public java.util.concurrent.Future run(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$3 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$3;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: org.apache.activemq.store.MessageStore val$destination>;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$3: org.apache.activemq.command.Message val$message>;
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;
}
}