class org.apache.activemq.store.journal.JournalPersistenceAdapter$5 extends java.lang.Object implements java.util.concurrent.Callable
{
final org.apache.activemq.store.journal.JournalTopicMessageStore val$ms;
final org.apache.activemq.store.journal.JournalPersistenceAdapter this$0;
void <init>(org.apache.activemq.store.journal.JournalPersistenceAdapter, org.apache.activemq.store.journal.JournalTopicMessageStore)
{
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter$5 v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter$5;
v := @parameter: org.apache.activemq.store.journal.JournalPersistenceAdapter;
v := @parameter: org.apache.activemq.store.journal.JournalTopicMessageStore;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapter$5: org.apache.activemq.store.journal.JournalPersistenceAdapter this$0> = v;
v.<org.apache.activemq.store.journal.JournalPersistenceAdapter$5: org.apache.activemq.store.journal.JournalTopicMessageStore val$ms> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.activeio.journal.RecordLocation call() throws java.lang.Exception
{
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter$5 v;
org.apache.activeio.journal.RecordLocation v;
v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter$5;
v = v.<org.apache.activemq.store.journal.JournalPersistenceAdapter$5: org.apache.activemq.store.journal.JournalTopicMessageStore val$ms>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activeio.journal.RecordLocation checkpoint()>();
return v;
}
}