public class org.apache.activemq.store.journal.JournalPersistenceAdapter extends java.lang.Object implements org.apache.activemq.store.PersistenceAdapter, org.apache.activeio.journal.JournalEventListener, org.apache.activemq.usage.UsageListener, org.apache.activemq.broker.BrokerServiceAware { private org.apache.activemq.broker.BrokerService brokerService; protected org.apache.activemq.thread.Scheduler scheduler; private static final org.slf4j.Logger LOG; private org.apache.activeio.journal.Journal journal; private org.apache.activemq.store.PersistenceAdapter longTermPersistence; private final org.apache.activemq.wireformat.WireFormat wireFormat; private final java.util.concurrent.ConcurrentMap queues; private final java.util.concurrent.ConcurrentMap topics; private org.apache.activemq.usage.SystemUsage usageManager; private long checkpointInterval; private long lastCheckpointRequest; private long lastCleanup; private int maxCheckpointWorkers; private int maxCheckpointMessageAddSize; private final org.apache.activemq.store.journal.JournalTransactionStore transactionStore; private java.util.concurrent.ThreadPoolExecutor checkpointExecutor; private org.apache.activemq.thread.TaskRunner checkpointTask; private java.util.concurrent.CountDownLatch nextCheckpointCountDownLatch; private boolean fullCheckPoint; private final java.util.concurrent.atomic.AtomicBoolean started; private final java.lang.Runnable periodicCheckpointTask; private org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory; private java.io.File directory; public void () { org.apache.activemq.store.journal.JournalTransactionStore v; java.util.concurrent.ConcurrentHashMap v, v; java.util.concurrent.atomic.AtomicBoolean v; long v, v; java.lang.Runnable v; java.util.concurrent.CountDownLatch v; org.apache.activemq.openwire.OpenWireFormat v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; specialinvoke v.()>(); v = new org.apache.activemq.openwire.OpenWireFormat; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v. = 300000L; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v. = 10; v. = 1048576; v = new org.apache.activemq.store.journal.JournalTransactionStore; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter)>(v); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = virtualinvoke v.(); v. = v; return; } public void (org.apache.activeio.journal.Journal, org.apache.activemq.store.PersistenceAdapter, org.apache.activemq.thread.TaskRunnerFactory) throws java.io.IOException { org.apache.activemq.store.journal.JournalTransactionStore v; java.util.concurrent.ConcurrentHashMap v, v; java.util.concurrent.atomic.AtomicBoolean v; long v, v; java.lang.Runnable v; org.apache.activeio.journal.Journal v; java.util.concurrent.CountDownLatch v; org.apache.activemq.openwire.OpenWireFormat v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.store.PersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activeio.journal.Journal; v := @parameter: org.apache.activemq.store.PersistenceAdapter; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; specialinvoke v.()>(); v = new org.apache.activemq.openwire.OpenWireFormat; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v. = 300000L; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v. = 10; v. = 1048576; v = new org.apache.activemq.store.journal.JournalTransactionStore; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter)>(v); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = virtualinvoke v.(); v. = v; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); return; } public void setTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory) { org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.thread.TaskRunnerFactory v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.thread.TaskRunnerFactory; v. = v; return; } public void setJournal(org.apache.activeio.journal.Journal) { org.apache.activeio.journal.Journal v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activeio.journal.Journal; v. = v; interfaceinvoke v.(v); return; } public void setPersistenceAdapter(org.apache.activemq.store.PersistenceAdapter) { org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.store.PersistenceAdapter; v. = v; return; } final java.lang.Runnable createPeriodicCheckpointTask() { org.apache.activemq.store.journal.JournalPersistenceAdapter$1 v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = new org.apache.activemq.store.journal.JournalPersistenceAdapter$1; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter)>(v); return v; } public void setUsageManager(org.apache.activemq.usage.SystemUsage) { org.apache.activemq.usage.SystemUsage v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.usage.SystemUsage; v. = v; v = v.; interfaceinvoke v.(v); return; } public java.util.Set getDestinations() { java.util.Set v, v, v; java.util.concurrent.ConcurrentMap v, v; java.util.HashSet v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.store.PersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = new java.util.HashSet; v = v.; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); return v; } private org.apache.activemq.store.MessageStore createMessageStore(org.apache.activemq.command.ActiveMQDestination) throws java.io.IOException { org.apache.activemq.store.MessageStore v; org.apache.activemq.store.TopicMessageStore v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; boolean v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(v); return v; } public org.apache.activemq.store.MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue) throws java.io.IOException { org.apache.activemq.store.MessageStore v; org.apache.activemq.store.journal.JournalMessageStore v; org.apache.activemq.command.ActiveMQQueue v; java.util.concurrent.ConcurrentMap v, v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.lang.Object v; org.apache.activemq.store.PersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.ActiveMQQueue; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = v.; v = interfaceinvoke v.(v); v = new org.apache.activemq.store.journal.JournalMessageStore; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter,org.apache.activemq.store.MessageStore,org.apache.activemq.command.ActiveMQDestination)>(v, v, v); v = v; v = v.; interfaceinvoke v.(v, v); label: return v; } public org.apache.activemq.store.TopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic) throws java.io.IOException { org.apache.activemq.store.journal.JournalTopicMessageStore v; java.util.concurrent.ConcurrentMap v, v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.store.TopicMessageStore v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.lang.Object v; org.apache.activemq.store.PersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.ActiveMQTopic; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = v.; v = interfaceinvoke v.(v); v = new org.apache.activemq.store.journal.JournalTopicMessageStore; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter,org.apache.activemq.store.TopicMessageStore,org.apache.activemq.command.ActiveMQTopic)>(v, v, v); v = v; v = v.; interfaceinvoke v.(v, v); label: return v; } public void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue) { org.apache.activemq.command.ActiveMQQueue v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.ActiveMQQueue; v = v.; interfaceinvoke v.(v); return; } public void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic) { org.apache.activemq.command.ActiveMQTopic v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.ActiveMQTopic; v = v.; interfaceinvoke v.(v); return; } public org.apache.activemq.store.TransactionStore createTransactionStore() throws java.io.IOException { org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.store.journal.JournalTransactionStore v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public long getLastMessageBrokerSequenceId() throws java.io.IOException { long v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; v = interfaceinvoke v.(); return v; } public void beginTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.broker.ConnectionContext; v = v.; interfaceinvoke v.(v); return; } public void commitTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.broker.ConnectionContext; v = v.; interfaceinvoke v.(v); return; } public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException { org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.broker.ConnectionContext; v = v.; interfaceinvoke v.(v); return; } public synchronized void start() throws java.lang.Exception { java.util.concurrent.ThreadPoolExecutor v; java.util.concurrent.atomic.AtomicBoolean v; long v, v; java.lang.Runnable v; org.apache.activemq.store.journal.JournalPersistenceAdapter$2 v; org.apache.activemq.store.journal.JournalPersistenceAdapter$3 v; int v, v, v; org.apache.activemq.usage.MemoryUsage v; org.apache.activemq.usage.SystemUsage v; boolean v, v; org.apache.activemq.broker.BrokerService v, v; org.apache.activemq.wireformat.WireFormat v; java.util.concurrent.LinkedBlockingQueue v; java.util.concurrent.TimeUnit v; org.apache.activemq.thread.TaskRunner v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.thread.Scheduler v, v, v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.store.PersistenceAdapter v, v, v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; v = virtualinvoke v.(0, 1); if v != 0 goto label; return; label: v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = new org.apache.activemq.store.journal.JournalPersistenceAdapter$2; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter)>(v); v = virtualinvoke v.(v, "ActiveMQ Journal Checkpoint Worker"); v. = v; v = new java.util.concurrent.ThreadPoolExecutor; v = v.; v = v.; v = ; v = new java.util.concurrent.LinkedBlockingQueue; specialinvoke v.()>(); v = new org.apache.activemq.store.journal.JournalPersistenceAdapter$3; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter)>(v); specialinvoke v.(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory)>(v, v, 30L, v, v, v); v. = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v instanceof org.apache.activemq.store.jdbc.JDBCPersistenceAdapter; if v == 0 goto label; v = v.; virtualinvoke v.(0); label: v = v.; interfaceinvoke v.(); virtualinvoke v.(); specialinvoke v.(); v = new org.apache.activemq.thread.Scheduler; specialinvoke v.(java.lang.String)>("Journal Scheduler"); v. = v; v = v.; virtualinvoke v.(); v = v.; v = v.; v = v.; v = v / 10L; virtualinvoke v.(v, v); return; } public void stop() throws java.lang.Exception { java.util.concurrent.ThreadPoolExecutor v; java.util.concurrent.atomic.AtomicBoolean v; java.lang.Runnable v; org.apache.activeio.journal.Journal v; java.util.concurrent.ConcurrentMap v, v; org.apache.activemq.usage.MemoryUsage v; org.apache.activemq.usage.SystemUsage v; java.lang.String v; boolean v; java.io.IOException v; java.lang.Exception v; org.apache.activemq.thread.TaskRunner v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.thread.Scheduler v, v; org.apache.activemq.store.PersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(1, 0); if v != 0 goto label; return; label: v = v.; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); virtualinvoke v.(1, 1); v = v.; interfaceinvoke v.(); v = v.; staticinvoke (v); v. = null; v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = null; label: v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to close journals: \u0001"); v = staticinvoke (v, v); label: v = v.; interfaceinvoke v.(); if v == null goto label; throw v; label: return; catch java.lang.Exception from label to label with label; } public org.apache.activemq.store.PersistenceAdapter getLongTermPersistence() { org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public org.apache.activemq.wireformat.WireFormat getWireFormat() { org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.wireformat.WireFormat v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public void overflowNotification(org.apache.activeio.journal.RecordLocation) { org.apache.activeio.journal.RecordLocation v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activeio.journal.RecordLocation; virtualinvoke v.(0, 1); return; } public void checkpoint(boolean, boolean) { java.lang.Throwable v; java.lang.IllegalStateException v; org.slf4j.Logger v, v; long v; org.apache.activeio.journal.Journal v; java.util.concurrent.CountDownLatch v; org.apache.activemq.thread.TaskRunner v; java.lang.InterruptedException v; java.lang.Thread v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.lang.String v; boolean v, v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: boolean; v := @parameter: boolean; label: v = v.; if v != null goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Journal is closed."); throw v; label: v = staticinvoke (); entermonitor v; label: v = v.; v. = v; if v == 0 goto label; v. = 1; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Waking for checkpoint to complete."); virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Request to start checkpoint failed: \u0001"); interfaceinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.InterruptedException from label to label with label; } public void checkpoint(boolean) { boolean v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: boolean; virtualinvoke v.(v, v); return; } public boolean doCheckpoint() { byte v; org.apache.activemq.store.journal.JournalPersistenceAdapter$5 v; org.apache.activemq.store.journal.JournalPersistenceAdapter$4 v; boolean v, v, v, v, v, v; java.util.Collection v, v; java.lang.Exception v, v, v; java.util.concurrent.CountDownLatch v, v; java.lang.Throwable v, v, v, v; java.util.concurrent.ThreadPoolExecutor v, v; java.util.concurrent.FutureTask v, v; long v, v, v, v; org.apache.activeio.journal.Journal v; org.apache.activeio.journal.RecordLocation v; java.util.ArrayList v; java.util.concurrent.ConcurrentMap v, v, v, v; int v, v, v, v; java.lang.String v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v; java.util.Iterator v, v, v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.lang.Object v, v, v, v; org.apache.activemq.store.PersistenceAdapter v, v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; entermonitor v; label: v = v.; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = v.; v. = 0; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; interfaceinvoke v.("Checkpoint started."); v = null; v = new java.util.ArrayList; v = v.; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v + v; specialinvoke v.(int)>(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; label: v = interfaceinvoke v.(); v = new java.util.concurrent.FutureTask; v = new org.apache.activemq.store.journal.JournalPersistenceAdapter$4; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter,org.apache.activemq.store.journal.JournalMessageStore)>(v, v); specialinvoke v.(java.util.concurrent.Callable)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to checkpoint a message store: \u0001"); interfaceinvoke v.(v, v); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; label: v = interfaceinvoke v.(); v = new java.util.concurrent.FutureTask; v = new org.apache.activemq.store.journal.JournalPersistenceAdapter$5; specialinvoke v.(org.apache.activemq.store.journal.JournalPersistenceAdapter,org.apache.activemq.store.journal.JournalTopicMessageStore)>(v, v); specialinvoke v.(java.util.concurrent.Callable)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to checkpoint a message store: \u0001"); interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; if v == null goto label; if v == null goto label; v = interfaceinvoke v.(v); if v >= 0 goto label; label: v = v; goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to checkpoint a message store: \u0001"); interfaceinvoke v.(v, v); label: if v == 0 goto label; label: if v == null goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Marking journal at: \u0001"); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v, 1); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to mark the Journal: \u0001"); interfaceinvoke v.(v, v); label: v = v.; v = v instanceof org.apache.activemq.store.jdbc.JDBCPersistenceAdapter; if v == 0 goto label; v = staticinvoke (); v = v.; v = v.; v = v + v; v = v cmp v; if v <= 0 goto label; v. = v; v = v.; virtualinvoke v.(); label: v = ; interfaceinvoke v.("Checkpoint done."); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: entermonitor v; label: v = v.; exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.command.DataStructure readCommand(org.apache.activeio.journal.RecordLocation) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.wireformat.WireFormat v; org.apache.activeio.packet.Packet v; java.io.IOException v, v, v; org.apache.activeio.journal.Journal v; org.apache.activeio.journal.RecordLocation v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.lang.Object v; org.apache.activemq.util.ByteSequence v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activeio.journal.RecordLocation; label: v = v.; v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(v); label: return v; label: v := @caughtexception; v = specialinvoke v.(v, v); throw v; label: v := @caughtexception; v = specialinvoke v.(v, v); throw v; catch org.apache.activeio.journal.InvalidRecordLocationException from label to label with label; catch java.io.IOException from label to label with label; } private void recover() throws java.lang.IllegalStateException, org.apache.activeio.journal.InvalidRecordLocationException, java.io.IOException, java.io.IOException { org.apache.activemq.filter.NonCachedMessageEvaluationContext v; org.apache.activemq.broker.ConnectionContext v; byte v, v, v, v, v, v; org.apache.activemq.util.ByteSequence v; org.apache.activemq.store.journal.JournalTransactionStore$Tx v; org.apache.activemq.command.DataStructure v; org.apache.activemq.store.journal.JournalTransactionStore v, v, v, v, v, v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.TransactionId v, v, v, v; java.io.IOException v, v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.store.journal.JournalMessageStore v, v, v; org.apache.activeio.packet.Packet v; boolean v, v, v, v, v; org.apache.activemq.command.MessageId v, v; org.apache.activemq.wireformat.WireFormat v; org.apache.activemq.command.ActiveMQDestination v, v, v; org.apache.activeio.journal.Journal v, v, v, v; org.apache.activeio.journal.RecordLocation v, v, v; int v; org.apache.activemq.store.MessageStore v, v, v; org.apache.activemq.command.MessageAck v, v, v; org.slf4j.Logger v, v, v, v, v; java.util.Iterator v; java.lang.Object v, v, v, v, v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = null; v = 0; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Journal Recovery Started from: \u0001"); interfaceinvoke v.(v); v = new org.apache.activemq.broker.ConnectionContext; v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext; specialinvoke v.()>(); specialinvoke v.(org.apache.activemq.filter.MessageEvaluationContext)>(v); label: v = v.; v = interfaceinvoke v.(v); v = v; if v == null goto label; v = v.; v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(v); v = v instanceof org.apache.activemq.command.Message; if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v, v, v); goto label; label: virtualinvoke v.(v, v); v = v + 1; goto label; label: v = interfaceinvoke v.(); tableswitch(v) { case 50: goto label; case 51: goto label; case 52: goto label; case 53: goto label; case 54: goto label; default: goto label; }; label: v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v + 1; goto label; label: v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = v.; virtualinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = virtualinvoke v.(); tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; default: goto label; }; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == null goto label; virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; if v != 0 goto label; v = v.; v = v.; virtualinvoke v.(v, v); label: v = v.; if v != 1 goto label; v = v.; v = v.; virtualinvoke v.(v, v); label: v = v.; if v != 3 goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = v + 1; goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid journal command type: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Recovery Failure: Could not replay: \u, reason: \u0001"); interfaceinvoke v.(v, v); goto label; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("TRACE Entry: \u0001"); interfaceinvoke v.(v); goto label; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown type of record in transaction log which will be discarded: \u0001"); interfaceinvoke v.(v); goto label; label: v = specialinvoke v.("RECOVERED", 1); v = v.; interfaceinvoke v.(v, 1); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Journal Recovered: \u message(s) in transactions recovered."); interfaceinvoke v.(v); return; catch java.io.IOException from label to label with label; } private java.io.IOException createReadException(org.apache.activeio.journal.RecordLocation, java.lang.Exception) { org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.io.IOException v; java.lang.String v; java.lang.Exception v; org.apache.activeio.journal.RecordLocation v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activeio.journal.RecordLocation; v := @parameter: java.lang.Exception; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to read to journal for: \u. Reason: \u0001"); v = staticinvoke (v, v); return v; } protected java.io.IOException createWriteException(org.apache.activemq.command.DataStructure, java.lang.Exception) { org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.command.DataStructure v; java.io.IOException v; java.lang.String v; java.lang.Exception v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.DataStructure; v := @parameter: java.lang.Exception; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to write to journal for: \u. Reason: \u0001"); v = staticinvoke (v, v); return v; } protected java.io.IOException createWriteException(java.lang.String, java.lang.Exception) { org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.io.IOException v; java.lang.String v, v; java.lang.Exception v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: java.lang.String; v := @parameter: java.lang.Exception; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to write to journal for command: \u. Reason: \u0001"); v = staticinvoke (v, v); return v; } protected java.io.IOException createRecoveryFailedException(java.lang.Exception) { org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.io.IOException v; java.lang.String v; java.lang.Exception v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: java.lang.Exception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to recover from journal. Reason: \u0001"); v = staticinvoke (v, v); return v; } public org.apache.activeio.journal.RecordLocation writeCommand(org.apache.activemq.command.DataStructure, boolean) throws java.io.IOException { org.apache.activemq.broker.BrokerService v; org.slf4j.Logger v; org.apache.activemq.wireformat.WireFormat v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activeio.packet.Packet v; java.io.IOException v, v; org.apache.activeio.journal.Journal v; org.apache.activeio.journal.RecordLocation v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.command.DataStructure v; org.apache.activemq.util.ByteSequence v; boolean v, v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.command.DataStructure; v := @parameter: boolean; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = interfaceinvoke v.(v, v); label: return v; label: v := @caughtexception; v = ; interfaceinvoke v.("Cannot write to the journal", v); v = v.; virtualinvoke v.(v); throw v; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("closed"); throw v; catch java.io.IOException from label to label with label; } private org.apache.activeio.journal.RecordLocation writeTraceMessage(java.lang.String, boolean) throws java.io.IOException { org.apache.activemq.command.JournalTrace v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; java.lang.String v; org.apache.activeio.journal.RecordLocation v; boolean v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: java.lang.String; v := @parameter: boolean; v = new org.apache.activemq.command.JournalTrace; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v, v); return v; } public void onUsageChanged(org.apache.activemq.usage.Usage, int, int) { org.apache.activemq.store.journal.JournalPersistenceAdapter v; int v, v, v, v, v, v; org.apache.activemq.usage.Usage v; boolean v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: org.apache.activemq.usage.Usage; v := @parameter: int; v := @parameter: int; v = v / 10; v = v * 10; v = v / 10; v = v * 10; if v < 70 goto label; if v >= v goto label; if v < 90 goto label; v = 1; goto label; label: v = 0; label: virtualinvoke v.(v, 1); label: return; } public org.apache.activemq.store.journal.JournalTransactionStore getTransactionStore() { org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.store.journal.JournalTransactionStore v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public void deleteAllMessages() throws java.io.IOException { java.lang.Throwable v; org.slf4j.Logger v; org.apache.activemq.wireformat.WireFormat v; org.apache.activeio.packet.Packet v; java.io.IOException v, v; org.apache.activeio.journal.Journal v, v; org.apache.activeio.journal.RecordLocation v; org.apache.activemq.command.JournalTrace v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; org.apache.activemq.store.PersistenceAdapter v; org.apache.activemq.util.ByteSequence v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; label: v = new org.apache.activemq.command.JournalTrace; specialinvoke v.()>(); virtualinvoke v.("DELETED"); v = v.; v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.("Journal deleted: "); label: goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); throw v; label: v = v.; interfaceinvoke v.(); return; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.usage.SystemUsage getUsageManager() { org.apache.activemq.usage.SystemUsage v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public int getMaxCheckpointMessageAddSize() { int v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public void setMaxCheckpointMessageAddSize(int) { int v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: int; v. = v; return; } public int getMaxCheckpointWorkers() { int v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.; return v; } public void setMaxCheckpointWorkers(int) { int v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v := @parameter: int; v. = v; return; } public long getCheckpointInterval() { long v; org.apache.activemq.store.journal.JournalPersistenceAdapter v; v := @this: org.apache.activemq.store.journal.JournalPersistenceAdapter; v = v.