class org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 extends org.apache.activemq.store.ProxyTopicMessageStore
{
final org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0;
void <init>(org.apache.activemq.store.kahadb.KahaDBTransactionStore, 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$2;
v := @parameter: org.apache.activemq.store.kahadb.KahaDBTransactionStore;
v := @parameter: org.apache.activemq.store.TopicMessageStore;
v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0> = v;
specialinvoke v.<org.apache.activemq.store.ProxyTopicMessageStore: void <init>(org.apache.activemq.store.TopicMessageStore)>(v);
return;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException
{
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$2 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.MessageStore,org.apache.activemq.command.Message)>(v, v, v);
return;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException
{
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$2 v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.MessageStore,org.apache.activemq.command.Message)>(v, v, v);
return;
}
public org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException
{
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.ListenableFuture v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.MessageStore,org.apache.activemq.command.Message)>(v, v, v);
return v;
}
public org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException
{
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.ListenableFuture v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.MessageStore,org.apache.activemq.command.Message)>(v, v, v);
return v;
}
public void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: void removeMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.MessageStore,org.apache.activemq.command.MessageAck)>(v, v, v);
return;
}
public void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.store.MessageStore,org.apache.activemq.command.MessageAck)>(v, v, v);
return;
}
public void acknowledge(org.apache.activemq.broker.ConnectionContext, java.lang.String, java.lang.String, org.apache.activemq.command.MessageId, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore 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;
java.lang.String v, v;
org.apache.activemq.store.kahadb.KahaDBTransactionStore$2 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBTransactionStore$2;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
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 = v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.kahadb.KahaDBTransactionStore this$0>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore$2: org.apache.activemq.store.MessageStore getDelegate()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBTransactionStore: 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)>(v, v, v, v, v, v);
return;
}
}