class org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3 extends java.lang.Object implements org.apache.activemq.store.kahadb.disk.page.Transaction$CallableClosure
{
final java.lang.String val$subscriptionKey;
final org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore this$1;
void <init>(org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore, java.lang.String)
{
java.lang.String v;
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore v;
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3 v;
v := @this: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3;
v := @parameter: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore this$1> = v;
v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: java.lang.String val$subscriptionKey> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public java.lang.Integer execute(org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException
{
long v;
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3 v;
java.lang.Integer v, v;
java.lang.String v, v;
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore v, v, v, v;
org.apache.activemq.store.kahadb.data.KahaDestination v;
org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v;
org.apache.activemq.store.kahadb.MessageDatabase$LastAck v;
org.apache.activemq.store.kahadb.KahaDBStore v, v, v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore: org.apache.activemq.store.kahadb.KahaDBStore this$0>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore: org.apache.activemq.store.kahadb.data.KahaDestination dest>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination,org.apache.activemq.store.kahadb.disk.page.Transaction)>(v, v);
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore: org.apache.activemq.store.kahadb.KahaDBStore this$0>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: java.lang.String val$subscriptionKey>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: org.apache.activemq.store.kahadb.MessageDatabase$LastAck getLastAck(org.apache.activemq.store.kahadb.disk.page.Transaction,org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination,java.lang.String)>(v, v, v);
if v != null goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
return v;
label:
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore this$1>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore: org.apache.activemq.store.kahadb.KahaDBStore this$0>;
v = v.<org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore$3: java.lang.String val$subscriptionKey>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.KahaDBStore: long getStoredMessageCount(org.apache.activemq.store.kahadb.disk.page.Transaction,org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination,java.lang.String)>(v, v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
}
}