public class org.apache.activemq.store.journal.JournalTopicMessageStore extends org.apache.activemq.store.journal.JournalMessageStore implements org.apache.activemq.store.TopicMessageStore
{
private static final org.slf4j.Logger LOG;
private org.apache.activemq.store.TopicMessageStore longTermStore;
private java.util.HashMap ackedLastAckLocations;
private final org.apache.activemq.store.MessageStoreSubscriptionStatistics stats;
public void <init>(org.apache.activemq.store.journal.JournalPersistenceAdapter, org.apache.activemq.store.TopicMessageStore, org.apache.activemq.command.ActiveMQTopic)
{
org.apache.activemq.command.ActiveMQTopic v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
java.util.HashMap v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.store.MessageStoreSubscriptionStatistics v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: org.apache.activemq.store.journal.JournalPersistenceAdapter;
v := @parameter: org.apache.activemq.store.TopicMessageStore;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.store.journal.JournalMessageStore: void <init>(org.apache.activemq.store.journal.JournalPersistenceAdapter,org.apache.activemq.store.MessageStore,org.apache.activemq.command.ActiveMQDestination)>(v, v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.store.journal.JournalTopicMessageStore: java.util.HashMap ackedLastAckLocations> = v;
v = new org.apache.activemq.store.MessageStoreSubscriptionStatistics;
specialinvoke v.<org.apache.activemq.store.MessageStoreSubscriptionStatistics: void <init>(boolean)>(0);
v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.MessageStoreSubscriptionStatistics stats> = v;
v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore> = v;
return;
}
public void recoverSubscription(java.lang.String, java.lang.String, org.apache.activemq.store.MessageRecoveryListener) throws java.lang.Exception
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalPersistenceAdapter peristenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void checkpoint(boolean,boolean)>(1, 1);
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void recoverSubscription(java.lang.String,java.lang.String,org.apache.activemq.store.MessageRecoveryListener)>(v, v, v);
return;
}
public void recoverNextMessages(java.lang.String, java.lang.String, int, org.apache.activemq.store.MessageRecoveryListener) throws java.lang.Exception
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
int v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalPersistenceAdapter peristenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void checkpoint(boolean,boolean)>(1, 1);
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void recoverNextMessages(java.lang.String,java.lang.String,int,org.apache.activemq.store.MessageRecoveryListener)>(v, v, v, v);
return;
}
public org.apache.activemq.command.SubscriptionInfo lookupSubscription(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.activemq.command.SubscriptionInfo v;
org.apache.activemq.store.TopicMessageStore v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
v = interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: org.apache.activemq.command.SubscriptionInfo lookupSubscription(java.lang.String,java.lang.String)>(v, v);
return v;
}
public void addSubscription(org.apache.activemq.command.SubscriptionInfo, boolean) throws java.io.IOException
{
org.apache.activemq.command.SubscriptionInfo v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: org.apache.activemq.command.SubscriptionInfo;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalPersistenceAdapter peristenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void checkpoint(boolean,boolean)>(1, 1);
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void addSubscription(org.apache.activemq.command.SubscriptionInfo,boolean)>(v, v);
return;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
specialinvoke v.<org.apache.activemq.store.journal.JournalMessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(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
{
java.lang.Throwable v;
org.apache.activemq.util.SubscriptionKey v;
org.apache.activemq.store.journal.JournalTransactionStore v;
org.apache.activemq.command.JournalTopicAck v;
long v;
org.apache.activeio.journal.RecordLocation v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.journal.JournalTopicMessageStore$1 v;
java.lang.String v, v, v, v;
org.apache.activemq.command.TransactionId v;
boolean v, v;
org.apache.activemq.command.MessageAck v;
org.slf4j.Logger v, v, v;
org.apache.activemq.command.MessageId v;
java.util.Set v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
org.apache.activemq.transaction.Transaction v, v, v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
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 = <org.apache.activemq.store.journal.JournalTopicMessageStore: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
v = new org.apache.activemq.command.JournalTopicAck;
specialinvoke v.<org.apache.activemq.command.JournalTopicAck: void <init>()>();
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.command.ActiveMQDestination destination>;
virtualinvoke v.<org.apache.activemq.command.JournalTopicAck: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<org.apache.activemq.command.JournalTopicAck: void setMessageId(org.apache.activemq.command.MessageId)>(v);
v = virtualinvoke v.<org.apache.activemq.command.MessageId: long getBrokerSequenceId()>();
virtualinvoke v.<org.apache.activemq.command.JournalTopicAck: void setMessageSequenceId(long)>(v);
virtualinvoke v.<org.apache.activemq.command.JournalTopicAck: void setSubscritionName(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.command.JournalTopicAck: void setClientId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.transaction.Transaction getTransaction()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.transaction.Transaction getTransaction()>();
v = virtualinvoke v.<org.apache.activemq.transaction.Transaction: org.apache.activemq.command.TransactionId getTransactionId()>();
goto label;
label:
v = null;
label:
virtualinvoke v.<org.apache.activemq.command.JournalTopicAck: void setTransactionId(org.apache.activemq.command.TransactionId)>(v);
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalPersistenceAdapter peristenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: org.apache.activeio.journal.RecordLocation writeCommand(org.apache.activemq.command.DataStructure,boolean)>(v, 0);
v = new org.apache.activemq.util.SubscriptionKey;
specialinvoke v.<org.apache.activemq.util.SubscriptionKey: void <init>(java.lang.String,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: boolean isInTransaction()>();
if v != 0 goto label;
if v == 0 goto label;
v = <org.apache.activemq.store.journal.JournalTopicMessageStore: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.MessageId,org.apache.activeio.journal.RecordLocation)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Journalled acknowledge for: \u, at: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
virtualinvoke v.<org.apache.activemq.store.journal.JournalTopicMessageStore: void acknowledge(org.apache.activemq.command.MessageId,org.apache.activeio.journal.RecordLocation,org.apache.activemq.util.SubscriptionKey)>(v, v, v);
goto label;
label:
if v == 0 goto label;
v = <org.apache.activemq.store.journal.JournalTopicMessageStore: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.MessageId,org.apache.activeio.journal.RecordLocation)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Journalled transacted acknowledge for: \u, at: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
entermonitor v;
label:
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: java.util.Set inFlightTxLocations>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalTransactionStore transactionStore>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalTransactionStore: void acknowledge(org.apache.activemq.store.journal.JournalTopicMessageStore,org.apache.activemq.command.JournalTopicAck,org.apache.activeio.journal.RecordLocation)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.transaction.Transaction getTransaction()>();
v = new org.apache.activemq.store.journal.JournalTopicMessageStore$1;
specialinvoke v.<org.apache.activemq.store.journal.JournalTopicMessageStore$1: void <init>(org.apache.activemq.store.journal.JournalTopicMessageStore,boolean,org.apache.activemq.command.MessageId,org.apache.activeio.journal.RecordLocation,org.apache.activemq.util.SubscriptionKey)>(v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.transaction.Transaction: void addSynchronization(org.apache.activemq.transaction.Synchronization)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void replayAcknowledge(org.apache.activemq.broker.ConnectionContext, java.lang.String, java.lang.String, org.apache.activemq.command.MessageId)
{
java.lang.Throwable v;
org.apache.activemq.command.SubscriptionInfo v;
org.slf4j.Logger v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.TopicMessageStore v, v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.activemq.command.MessageId;
label:
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
v = interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: org.apache.activemq.command.SubscriptionInfo lookupSubscription(java.lang.String,java.lang.String)>(v, v);
if v == null goto label;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
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, null);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.store.journal.JournalTopicMessageStore: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.MessageId,java.lang.Throwable)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not replay acknowledge for message \'\u0001\'.  Message may have already been acknowledged. reason: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected void acknowledge(org.apache.activemq.command.MessageId, org.apache.activeio.journal.RecordLocation, org.apache.activemq.util.SubscriptionKey)
{
java.lang.Throwable v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.util.SubscriptionKey v;
java.util.HashMap v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activeio.journal.RecordLocation v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: org.apache.activemq.command.MessageId;
v := @parameter: org.apache.activeio.journal.RecordLocation;
v := @parameter: org.apache.activemq.util.SubscriptionKey;
entermonitor v;
label:
v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activeio.journal.RecordLocation lastLocation> = v;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: java.util.HashMap ackedLastAckLocations>;
virtualinvoke v.<java.util.HashMap: 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;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activeio.journal.RecordLocation checkpoint() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.store.journal.JournalTopicMessageStore$2 v;
java.util.HashMap v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activeio.journal.RecordLocation v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
entermonitor v;
label:
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: java.util.HashMap ackedLastAckLocations>;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.store.journal.JournalTopicMessageStore: java.util.HashMap ackedLastAckLocations> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = new org.apache.activemq.store.journal.JournalTopicMessageStore$2;
specialinvoke v.<org.apache.activemq.store.journal.JournalTopicMessageStore$2: void <init>(org.apache.activemq.store.journal.JournalTopicMessageStore,java.util.HashMap)>(v, v);
v = specialinvoke v.<org.apache.activemq.store.journal.JournalMessageStore: org.apache.activeio.journal.RecordLocation checkpoint(org.apache.activemq.util.Callback)>(v);
return v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.store.TopicMessageStore getLongTermTopicMessageStore()
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
return v;
}
public void deleteSubscription(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.activemq.store.TopicMessageStore v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void deleteSubscription(java.lang.String,java.lang.String)>(v, v);
return;
}
public org.apache.activemq.command.SubscriptionInfo[] getAllSubscriptions() throws java.io.IOException
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.command.SubscriptionInfo[] v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
v = interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: org.apache.activemq.command.SubscriptionInfo[] getAllSubscriptions()>();
return v;
}
public int getMessageCount(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
int v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalPersistenceAdapter peristenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void checkpoint(boolean,boolean)>(1, 1);
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
v = interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: int getMessageCount(java.lang.String,java.lang.String)>(v, v);
return v;
}
public long getMessageSize(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.store.journal.JournalPersistenceAdapter v;
long v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.journal.JournalPersistenceAdapter peristenceAdapter>;
virtualinvoke v.<org.apache.activemq.store.journal.JournalPersistenceAdapter: void checkpoint(boolean,boolean)>(1, 1);
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
v = interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: long getMessageSize(java.lang.String,java.lang.String)>(v, v);
return v;
}
public void resetBatching(java.lang.String, java.lang.String)
{
org.apache.activemq.store.TopicMessageStore v;
java.lang.String v, v;
org.apache.activemq.store.journal.JournalTopicMessageStore v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.TopicMessageStore longTermStore>;
interfaceinvoke v.<org.apache.activemq.store.TopicMessageStore: void resetBatching(java.lang.String,java.lang.String)>(v, v);
return;
}
public org.apache.activemq.store.MessageStoreSubscriptionStatistics getMessageStoreSubStatistics()
{
org.apache.activemq.store.journal.JournalTopicMessageStore v;
org.apache.activemq.store.MessageStoreSubscriptionStatistics v;
v := @this: org.apache.activemq.store.journal.JournalTopicMessageStore;
v = v.<org.apache.activemq.store.journal.JournalTopicMessageStore: org.apache.activemq.store.MessageStoreSubscriptionStatistics stats>;
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/journal/JournalTopicMessageStore;");
<org.apache.activemq.store.journal.JournalTopicMessageStore: org.slf4j.Logger LOG> = v;
return;
}
}