public class org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore extends org.apache.activemq.store.AbstractMessageStore implements scala.Product, scala.Serializable
{
private final org.apache.activemq.command.ActiveMQDestination dest;
private final long key;
private final java.util.concurrent.atomic.AtomicLong lastSeq;
private long cursorPosition;
private final java.util.HashSet preparedAcks;
private final java.util.LinkedList pendingCursorAdds;
public final org.apache.activemq.leveldb.LevelDBStore $outer;
public org.apache.activemq.command.ActiveMQDestination dest()
{
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest>;
return v;
}
public long key()
{
long v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key>;
return v;
}
public java.util.concurrent.atomic.AtomicLong lastSeq()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.concurrent.atomic.AtomicLong lastSeq>;
return v;
}
public long cursorPosition()
{
long v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorPosition>;
return v;
}
public void cursorPosition_$eq(long)
{
long v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorPosition> = v;
return;
}
public java.util.HashSet preparedAcks()
{
java.util.HashSet v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.HashSet preparedAcks>;
return v;
}
public java.util.LinkedList pendingCursorAdds()
{
java.util.LinkedList v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.LinkedList pendingCursorAdds>;
return v;
}
public long cursorResetPosition()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
return 0L;
}
public org.apache.activemq.leveldb.CountDownFuture doAdd(org.apache.activemq.leveldb.DelayableUOW, org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean)
{
java.lang.Throwable v, v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v, v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$doAdd$1 v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
java.lang.Long v, v;
org.apache.activemq.store.IndexListener v, v;
java.util.LinkedList v, v;
org.apache.activemq.leveldb.CountDownFuture v;
boolean v, v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.leveldb.DelayableUOW v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anon$7 v;
org.apache.activemq.leveldb.LevelDBStore v, v;
java.util.concurrent.atomic.AtomicLong v, v;
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.store.IndexListener$MessageContext v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.leveldb.DelayableUOW;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.openwire.OpenWireFormat wireFormat()>();
virtualinvoke v.<org.apache.activemq.command.Message: void beforeMarshall(org.apache.activemq.wireformat.WireFormat)>(v);
virtualinvoke v.<org.apache.activemq.command.Message: int incrementReferenceCount()>();
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$doAdd$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$doAdd$1: void <init>(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,org.apache.activemq.command.Message)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: void addCompleteListener(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.concurrent.atomic.AtomicLong lastSeq()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.concurrent.atomic.AtomicLong lastSeq()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId getMessageId()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
virtualinvoke v.<org.apache.activemq.command.MessageId: void setFutureOrSequenceLong(java.lang.Object)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.store.IndexListener indexListener>;
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.LinkedList pendingCursorAdds()>();
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.LinkedList pendingCursorAdds()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
staticinvoke <scala.runtime.BoxesRunTime: java.lang.Boolean boxToBoolean(boolean)>(v);
exitmonitor v;
label:
v = v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.store.IndexListener indexListener>;
v = new org.apache.activemq.store.IndexListener$MessageContext;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anon$7;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anon$7: void <init>(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,long)>(v, v);
specialinvoke v.<org.apache.activemq.store.IndexListener$MessageContext: void <init>(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,java.lang.Runnable)>(v, v, v);
interfaceinvoke v.<org.apache.activemq.store.IndexListener: void onAdd(org.apache.activemq.store.IndexListener$MessageContext)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: org.apache.activemq.leveldb.CountDownFuture enqueue(long,long,org.apache.activemq.command.Message,boolean)>(v, v, v, v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, 0);
return v;
}
public org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean)
{
org.apache.activemq.command.MessageId v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.LevelDBStore$ v;
org.apache.activemq.leveldb.LevelDBStore v, v, v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$asyncAddQueueMessage$1 v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.leveldb.LevelDBStore$Transaction v;
java.lang.Object v;
org.apache.activemq.command.TransactionId v, v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId getMessageId()>();
virtualinvoke v.<org.apache.activemq.command.MessageId: void setEntryLocator(java.lang.Object)>(null);
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$asyncAddQueueMessage$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$asyncAddQueueMessage$1: void <init>(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object withUow(scala.Function)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction transaction(org.apache.activemq.command.TransactionId)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: scala.collection.mutable.ListBuffer add(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, v, v);
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.store.InlineListenableFuture DONE()>();
label:
return v;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, 0);
return;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.LevelDBStore$ v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void waitOn(java.util.concurrent.Future)>(v);
return;
}
public void updateMessage(org.apache.activemq.command.Message)
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$updateMessage$1 v;
org.apache.activemq.command.Message v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.LevelDBStore v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$updateMessage$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$updateMessage$1: void <init>(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,org.apache.activemq.command.Message)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object withUow(scala.Function)>(v);
return;
}
public org.apache.activemq.leveldb.CountDownFuture doRemove(org.apache.activemq.leveldb.DelayableUOW, org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageId v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v;
org.apache.activemq.leveldb.DelayableUOW v;
org.apache.activemq.leveldb.CountDownFuture v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.leveldb.DelayableUOW;
v := @parameter: org.apache.activemq.command.MessageId;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: org.apache.activemq.leveldb.CountDownFuture dequeue(long,org.apache.activemq.command.MessageId)>(v, v);
return v;
}
public void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.LevelDBStore$ v;
org.apache.activemq.leveldb.LevelDBStore v, v, v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.leveldb.LevelDBStore$Transaction v;
java.lang.Object v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$removeAsyncMessage$1 v;
org.apache.activemq.command.TransactionId v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessageAck;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
if v != null goto label;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$removeAsyncMessage$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$removeAsyncMessage$1: void <init>(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,org.apache.activemq.command.MessageAck)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.Object withUow(scala.Function)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: void waitOn(java.util.concurrent.Future)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId getTransactionId()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$Transaction transaction(org.apache.activemq.command.TransactionId)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$Transaction: scala.collection.mutable.ListBuffer remove(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore,org.apache.activemq.command.MessageAck)>(v, v);
label:
return;
}
public void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessageAck;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
return;
}
public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageId v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
java.io.IOException v;
org.apache.activemq.leveldb.LevelDBStore v, v;
scala.collection.mutable.StringBuilder v, v, v;
org.apache.activemq.command.Message v;
org.apache.activemq.leveldb.DBManager v;
java.lang.String v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.command.MessageId;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId)>(v);
if v != null goto label;
v = new java.io.IOException;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("Message id not found: ");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public void removeAllMessages(org.apache.activemq.broker.ConnectionContext)
{
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.DBManager v;
long v, v;
org.apache.activemq.leveldb.LevelDBStore v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void collectionEmpty(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorResetPosition()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void cursorPosition_$eq(long)>(v);
return;
}
public int getMessageCount()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.DBManager v;
long v, v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long collectionSize(long)>(v);
return v;
}
public boolean isEmpty()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
org.apache.activemq.leveldb.DBManager v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: boolean collectionIsEmpty(long)>(v);
return v;
}
public long getCursorPendingLimit()
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v;
scala.Option v;
scala.Option$ v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$getCursorPendingLimit$1 v;
java.lang.Object v, v;
java.util.LinkedList v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.LinkedList pendingCursorAdds()>();
entermonitor v;
label:
v = <scala.Option$: scala.Option$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.LinkedList pendingCursorAdds()>();
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object peek()>();
v = virtualinvoke v.<scala.Option$: scala.Option apply(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$getCursorPendingLimit$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore$$anonfun$getCursorPendingLimit$1: void <init>(org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore)>(v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
exitmonitor v;
label:
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void recover(org.apache.activemq.store.MessageRecoveryListener)
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v, v, v, v, v;
org.apache.activemq.leveldb.LevelDBStore v, v, v;
java.util.HashSet v;
org.apache.activemq.leveldb.DBManager v, v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.HashSet preparedAcks()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorResetPosition()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long getCursorPendingLimit()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long cursorMessages$default$6()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long cursorMessages(java.util.HashSet,long,org.apache.activemq.store.MessageRecoveryListener,long,long,long)>(v, v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void cursorPosition_$eq(long)>(v);
return;
}
public void resetBatching()
{
long v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorResetPosition()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void cursorPosition_$eq(long)>(v);
return;
}
public void recoverNextMessages(int, org.apache.activemq.store.MessageRecoveryListener)
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v, v, v, v;
org.apache.activemq.leveldb.LevelDBStore v, v;
java.util.HashSet v;
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: int;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void check_running()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.HashSet preparedAcks()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorPosition()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long getCursorPendingLimit()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long cursorMessages(java.util.HashSet,long,org.apache.activemq.store.MessageRecoveryListener,long,long,long)>(v, v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void cursorPosition_$eq(long)>(v);
return;
}
public void setBatch(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageId v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v, v, v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.command.MessageId;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long getCursorPendingLimit()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long queuePosition(org.apache.activemq.command.MessageId)>(v);
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v + 1L;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void cursorPosition_$eq(long)>(v);
return;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore copy(org.apache.activemq.command.ActiveMQDestination, long)
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v, v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: long;
v = new org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: void <init>(org.apache.activemq.leveldb.LevelDBStore,org.apache.activemq.command.ActiveMQDestination,long)>(v, v, v);
return v;
}
public org.apache.activemq.command.ActiveMQDestination copy$default$1()
{
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest()>();
return v;
}
public long copy$default$2()
{
long v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
return v;
}
public java.lang.String productPrefix()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
return "LevelDBMessageStore";
}
public int productArity()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
return 2;
}
public java.lang.Object productElement(int)
{
java.lang.IndexOutOfBoundsException v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
int v;
java.lang.Comparable v;
long v;
java.lang.String v;
java.lang.Integer v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: int;
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
default: goto label;
};
label:
v = new java.lang.IndexOutOfBoundsException;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(v);
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
specialinvoke v.<java.lang.IndexOutOfBoundsException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest()>();
label:
return v;
}
public scala.collection.Iterator productIterator()
{
scala.runtime.ScalaRunTime$ v;
scala.collection.Iterator v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = <scala.runtime.ScalaRunTime$: scala.runtime.ScalaRunTime$ MODULE$>;
v = virtualinvoke v.<scala.runtime.ScalaRunTime$: scala.collection.Iterator typedProductIterator(scala.Product)>(v);
return v;
}
public boolean canEqual(java.lang.Object)
{
java.lang.Object v;
boolean v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
return v;
}
public int hashCode()
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v;
org.apache.activemq.command.ActiveMQDestination v;
int v, v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest()>();
v = staticinvoke <scala.runtime.Statics: int anyHash(java.lang.Object)>(v);
v = staticinvoke <scala.runtime.Statics: int mix(int,int)>(-889275714, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = staticinvoke <scala.runtime.Statics: int longHash(long)>(v);
v = staticinvoke <scala.runtime.Statics: int mix(int,int)>(v, v);
v = staticinvoke <scala.runtime.Statics: int finalizeHash(int,int)>(v, 2);
return v;
}
public java.lang.String toString()
{
scala.runtime.ScalaRunTime$ v;
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v = <scala.runtime.ScalaRunTime$: scala.runtime.ScalaRunTime$ MODULE$>;
v = virtualinvoke v.<scala.runtime.ScalaRunTime$: java.lang.String _toString(scala.Product)>(v);
return v;
}
public boolean equals(java.lang.Object)
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v, v;
org.apache.activemq.leveldb.LevelDBStore v, v;
org.apache.activemq.command.ActiveMQDestination v, v;
byte v;
java.lang.Object v;
boolean v, v, v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: java.lang.Object;
if v == v goto label;
v = v instanceof org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBStore$LevelDBMessageStore$$$outer()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest()>();
if v != null goto label;
if v == null goto label;
goto label;
label:
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key()>();
v = v cmp v;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: boolean canEqual(java.lang.Object)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void <init>(org.apache.activemq.leveldb.LevelDBStore, org.apache.activemq.command.ActiveMQDestination, long)
{
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.command.ActiveMQDestination v;
java.util.HashSet v;
java.util.concurrent.atomic.AtomicLong v, v;
org.apache.activemq.leveldb.DBManager v;
java.util.LinkedList v;
v := @this: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore;
v := @parameter: org.apache.activemq.leveldb.LevelDBStore;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.command.ActiveMQDestination dest> = v;
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long key> = v;
if v != null goto label;
throw null;
label:
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: org.apache.activemq.leveldb.LevelDBStore $outer> = v;
specialinvoke v.<org.apache.activemq.store.AbstractMessageStore: void <init>(org.apache.activemq.command.ActiveMQDestination)>(v);
staticinvoke <scala.Product$class: void $init$(scala.Product)>(v);
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.concurrent.atomic.AtomicLong lastSeq> = v;
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: long cursorPosition> = 0L;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.HashSet preparedAcks> = v;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.LinkedList pendingCursorAdds> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore: java.util.concurrent.atomic.AtomicLong lastSeq()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long getLastQueueEntrySeq(long)>(v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
return;
}
}