public class org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1 extends java.lang.Object implements org.fusesource.hawtdispatch.transport.TransportServerListener
{
private final org.apache.activemq.leveldb.replicated.MasterLevelDBStore $outer;
public void onAccept(org.fusesource.hawtdispatch.transport.Transport)
{
java.net.SocketAddress v;
java.util.concurrent.Executor v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session v;
scala.collection.mutable.StringBuilder v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1 v;
org.fusesource.hawtdispatch.package$ v;
org.fusesource.hawtdispatch.transport.Transport v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v;
java.lang.String v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1;
v := @parameter: org.fusesource.hawtdispatch.transport.Transport;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
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)>("connection from ");
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: java.net.SocketAddress getRemoteAddress()>();
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()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.DispatchQueue createQueue(java.lang.String)>(v);
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: void setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1: org.apache.activemq.leveldb.replicated.MasterLevelDBStore $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: void setBlockingExecutor(java.util.concurrent.Executor)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1: org.apache.activemq.leveldb.replicated.MasterLevelDBStore $outer>;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore,org.fusesource.hawtdispatch.transport.Transport)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: void start()>();
return;
}
public void onAcceptError(java.lang.Exception)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1 v;
java.lang.Exception v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1;
v := @parameter: java.lang.Exception;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void warn(java.lang.Throwable)>(v);
return;
}
public void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1 v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
if v != null goto label;
throw null;
label:
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1: org.apache.activemq.leveldb.replicated.MasterLevelDBStore $outer> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
}