public class org.apache.activemq.leveldb.replicated.ElectingLevelDBStore extends org.apache.activemq.leveldb.replicated.ProxyLevelDBStore
{
private java.lang.String zkAddress;
private java.lang.String zkPassword;
private java.lang.String zkPath;
private java.lang.String zkSessionTimeout;
private java.lang.String brokerName;
private java.lang.String container;
private java.lang.String hostname;
private java.lang.String connectUrl;
private java.lang.String bind;
private int weight;
private int replicas;
private java.lang.String sync;
private java.lang.String securityToken;
private java.io.File directory;
private long logSize;
private java.lang.String indexFactory;
private boolean verifyChecksums;
private int indexMaxOpenFiles;
private int indexBlockRestartInterval;
private boolean paranoidChecks;
private int indexWriteBufferSize;
private int indexBlockSize;
private java.lang.String indexCompression;
private java.lang.String logCompression;
private long indexCacheSize;
private int flushDelay;
private int asyncBufferSize;
private boolean monitorStats;
private int failoverProducersAuditDepth;
private int maxFailoverProducersToTrack;
private org.apache.activemq.leveldb.replicated.MasterLevelDBStore master;
private org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave;
private org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client;
private org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group;
private long position;
private org.apache.activemq.usage.SystemUsage usageManager;
private final java.util.concurrent.CountDownLatch master_started_latch;
private final java.util.concurrent.atomic.AtomicBoolean master_started;
private final java.util.concurrent.CountDownLatch stopped_latch;
private final java.util.concurrent.atomic.AtomicBoolean master_stopped;
public static void trace(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void trace(java.lang.Throwable)>(v);
return;
}
public static void trace(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void trace(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void trace(scala.Function, scala.collection.Seq)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void trace(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void debug(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void debug(java.lang.Throwable)>(v);
return;
}
public static void debug(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void debug(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void debug(scala.Function, scala.collection.Seq)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void info(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void info(java.lang.Throwable)>(v);
return;
}
public static void info(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void info(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void info(scala.Function, scala.collection.Seq)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void warn(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void warn(java.lang.Throwable)>(v);
return;
}
public static void warn(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void warn(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void warn(scala.Function, scala.collection.Seq)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void warn(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void error(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void error(java.lang.Throwable)>(v);
return;
}
public static void error(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void error(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void error(scala.Function, scala.collection.Seq)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
scala.Function v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void error(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
org.slf4j.Logger v;
v := @parameter: org.slf4j.Logger;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)>(v);
return;
}
public static org.slf4j.Logger log()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
org.slf4j.Logger v;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.slf4j.Logger log()>();
return v;
}
public static java.lang.String machine_hostname()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
java.lang.String v;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: java.lang.String machine_hostname()>();
return v;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBStore proxy_target()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
return v;
}
public java.lang.String zkAddress()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress>;
return v;
}
public void zkAddress_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress> = v;
return;
}
public void setZkAddress(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress> = v;
return;
}
public java.lang.String zkPassword()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPassword>;
return v;
}
public void zkPassword_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPassword> = v;
return;
}
public void setZkPassword(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPassword> = v;
return;
}
public java.lang.String zkPath()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath>;
return v;
}
public void zkPath_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath> = v;
return;
}
public void setZkPath(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath> = v;
return;
}
public java.lang.String zkSessionTimeout()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkSessionTimeout>;
return v;
}
public void zkSessionTimeout_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkSessionTimeout> = v;
return;
}
public void setZkSessionTimeout(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkSessionTimeout> = v;
return;
}
public java.lang.String brokerName()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String brokerName>;
return v;
}
public void brokerName_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String brokerName> = v;
return;
}
public java.lang.String container()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String container>;
return v;
}
public void container_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String container> = v;
return;
}
public void setContainer(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String container> = v;
return;
}
public java.lang.String hostname()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String hostname>;
return v;
}
public void hostname_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String hostname> = v;
return;
}
public void setHostname(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String hostname> = v;
return;
}
public java.lang.String connectUrl()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String connectUrl>;
return v;
}
public void connectUrl_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String connectUrl> = v;
return;
}
public void setConnectUrl(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String connectUrl> = v;
return;
}
public java.lang.String bind()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String bind>;
return v;
}
public void bind_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String bind> = v;
return;
}
public void setBind(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String bind> = v;
return;
}
public int weight()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int weight>;
return v;
}
public void weight_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int weight> = v;
return;
}
public void setWeight(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int weight> = v;
return;
}
public int replicas()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas>;
return v;
}
public void replicas_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas> = v;
return;
}
public void setReplicas(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas> = v;
return;
}
public java.lang.String sync()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String sync>;
return v;
}
public void sync_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String sync> = v;
return;
}
public void setSync(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String sync> = v;
return;
}
public int clusterSizeQuorum()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
int v, v, v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas()>();
v = v / 2;
v = v + 1;
return v;
}
public java.lang.String securityToken()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String securityToken>;
return v;
}
public void securityToken_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String securityToken> = v;
return;
}
public void setSecurityToken(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String securityToken> = v;
return;
}
public java.io.File directory()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory>;
return v;
}
public void directory_$eq(java.io.File)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.io.File;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory> = v;
return;
}
public void setDirectory(java.io.File)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.io.File;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void directory_$eq(java.io.File)>(v);
return;
}
public java.io.File getDirectory()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
return v;
}
public long logSize()
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long logSize>;
return v;
}
public void logSize_$eq(long)
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long logSize> = v;
return;
}
public void setLogSize(long)
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long logSize> = v;
return;
}
public java.lang.String indexFactory()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexFactory>;
return v;
}
public void indexFactory_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexFactory> = v;
return;
}
public void setIndexFactory(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexFactory> = v;
return;
}
public boolean verifyChecksums()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean verifyChecksums>;
return v;
}
public void verifyChecksums_$eq(boolean)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean verifyChecksums> = v;
return;
}
public void setVerifyChecksums(boolean)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean verifyChecksums> = v;
return;
}
public int indexMaxOpenFiles()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexMaxOpenFiles>;
return v;
}
public void indexMaxOpenFiles_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexMaxOpenFiles> = v;
return;
}
public void setIndexMaxOpenFiles(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexMaxOpenFiles> = v;
return;
}
public int indexBlockRestartInterval()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockRestartInterval>;
return v;
}
public void indexBlockRestartInterval_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockRestartInterval> = v;
return;
}
public void setIndexBlockRestartInterval(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockRestartInterval> = v;
return;
}
public boolean paranoidChecks()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean paranoidChecks>;
return v;
}
public void paranoidChecks_$eq(boolean)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean paranoidChecks> = v;
return;
}
public void setParanoidChecks(boolean)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean paranoidChecks> = v;
return;
}
public int indexWriteBufferSize()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexWriteBufferSize>;
return v;
}
public void indexWriteBufferSize_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexWriteBufferSize> = v;
return;
}
public void setIndexWriteBufferSize(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexWriteBufferSize> = v;
return;
}
public int indexBlockSize()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockSize>;
return v;
}
public void indexBlockSize_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockSize> = v;
return;
}
public void setIndexBlockSize(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockSize> = v;
return;
}
public java.lang.String indexCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexCompression>;
return v;
}
public void indexCompression_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexCompression> = v;
return;
}
public void setIndexCompression(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexCompression> = v;
return;
}
public java.lang.String logCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String logCompression>;
return v;
}
public void logCompression_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String logCompression> = v;
return;
}
public void setLogCompression(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String logCompression> = v;
return;
}
public long indexCacheSize()
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long indexCacheSize>;
return v;
}
public void indexCacheSize_$eq(long)
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long indexCacheSize> = v;
return;
}
public void setIndexCacheSize(long)
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long indexCacheSize> = v;
return;
}
public int flushDelay()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int flushDelay>;
return v;
}
public void flushDelay_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int flushDelay> = v;
return;
}
public void setFlushDelay(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int flushDelay> = v;
return;
}
public int asyncBufferSize()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int asyncBufferSize>;
return v;
}
public void asyncBufferSize_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int asyncBufferSize> = v;
return;
}
public void setAsyncBufferSize(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int asyncBufferSize> = v;
return;
}
public boolean monitorStats()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean monitorStats>;
return v;
}
public void monitorStats_$eq(boolean)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean monitorStats> = v;
return;
}
public void setMonitorStats(boolean)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean monitorStats> = v;
return;
}
public int failoverProducersAuditDepth()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int failoverProducersAuditDepth>;
return v;
}
public void failoverProducersAuditDepth_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int failoverProducersAuditDepth> = v;
return;
}
public void setFailoverProducersAuditDepth(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int failoverProducersAuditDepth> = v;
return;
}
public int maxFailoverProducersToTrack()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int maxFailoverProducersToTrack>;
return v;
}
public void maxFailoverProducersToTrack_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int maxFailoverProducersToTrack> = v;
return;
}
public void setMaxFailoverProducersToTrack(int)
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int maxFailoverProducersToTrack> = v;
return;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master>;
return v;
}
public void master_$eq(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master> = v;
return;
}
public org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave>;
return v;
}
public void slave_$eq(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore)
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave> = v;
return;
}
public org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client>;
return v;
}
public void zk_client_$eq(org.apache.activemq.leveldb.replicated.groups.ZKClient)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.leveldb.replicated.groups.ZKClient;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client> = v;
return;
}
public org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group>;
return v;
}
public void zk_group_$eq(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group> = v;
return;
}
public long position()
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long position>;
return v;
}
public void position_$eq(long)
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long position> = v;
return;
}
public java.lang.String toString()
{
scala.collection.mutable.WrappedArray v;
java.lang.Object[] v;
java.io.File v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v, v;
java.lang.String v, v, v, v, v;
scala.collection.immutable.StringOps v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>("Replicated LevelDB[%s, %s/%s]");
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress()>();
v[1] = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath()>();
v[2] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.immutable.StringOps: java.lang.String format(scala.collection.Seq)>(v);
return v;
}
public org.apache.activemq.usage.SystemUsage usageManager()
{
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.usage.SystemUsage usageManager>;
return v;
}
public void usageManager_$eq(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.usage.SystemUsage;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.usage.SystemUsage usageManager> = v;
return;
}
public void setUsageManager(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.usage.SystemUsage;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void usageManager_$eq(org.apache.activemq.usage.SystemUsage)>(v);
return;
}
public java.lang.String node_id()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.lang.String v;
org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$ v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$: org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$: java.lang.String node_id(java.io.File)>(v);
return v;
}
public void init()
{
org.apache.activemq.leveldb.RecordLog v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v, v;
org.apache.activemq.broker.Locker v;
org.apache.activemq.broker.jmx.ManagementContext v;
boolean v;
org.linkedin.util.clock.Timespan v, v;
org.apache.activemq.broker.BrokerService v, v, v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v, v;
javax.management.ObjectName v;
org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreView v;
java.lang.Throwable v;
org.apache.activemq.leveldb.RecordLog$LogAppender v;
java.lang.Object[] v, v;
long v, v, v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroupFactory$ v;
org.apache.activemq.leveldb.replicated.MasterElector v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v, v;
java.lang.String v, v, v, v, v;
scala.collection.mutable.WrappedArray v, v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v, v, v, v, v;
java.io.File v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$init$2 v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$init$3 v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = new org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreView;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreView: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: javax.management.ObjectName objectName()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = new org.apache.activemq.leveldb.RecordLog;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
specialinvoke v.<org.apache.activemq.leveldb.RecordLog: void <init>(java.io.File,java.lang.String)>(v, ".log");
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long logSize()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void logSize_$eq(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long open$default$1()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: java.lang.Object open(long)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: org.apache.activemq.leveldb.RecordLog$LogAppender current_appender()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog$LogAppender: long append_position()>();
label:
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void close()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void position_$eq(long)>(v);
v = new org.apache.activemq.leveldb.replicated.groups.ZKClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkSessionTimeout()>();
v = staticinvoke <org.linkedin.util.clock.Timespan: org.linkedin.util.clock.Timespan parse(java.lang.String)>(v);
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void <init>(java.lang.String,org.linkedin.util.clock.Timespan,org.apache.zookeeper.Watcher)>(v, v, null);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void zk_client_$eq(org.apache.activemq.leveldb.replicated.groups.ZKClient)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPassword()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPassword()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void setPassword(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void start()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()>();
v = staticinvoke <org.linkedin.util.clock.Timespan: org.linkedin.util.clock.Timespan parse(java.lang.String)>("30s");
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void waitForConnected(org.linkedin.util.clock.Timespan)>(v);
v = <org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroupFactory$: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroupFactory$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroupFactory$: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup create(org.apache.activemq.leveldb.replicated.groups.ZKClient,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void zk_group_$eq(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterElector;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterElector: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$init$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$init$2: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterElector: void start(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$init$3;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$init$3: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterElector: void join()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void setUseLock(boolean)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.Locker createDefaultLocker()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void setLocker(org.apache.activemq.broker.Locker)>(v);
return;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void close()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.activemq.broker.Locker createDefaultLocker()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anon$1 v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anon$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anon$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
return v;
}
public java.util.concurrent.CountDownLatch master_started_latch()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.CountDownLatch master_started_latch>;
return v;
}
public java.util.concurrent.atomic.AtomicBoolean master_started()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_started>;
return v;
}
public void start_master(scala.Function)
{
java.util.concurrent.atomic.AtomicBoolean v;
scala.Function v;
org.fusesource.hawtdispatch.package$ v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v, v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$2 v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1 v;
boolean v;
org.fusesource.hawtdispatch.Task v, v;
java.util.concurrent.Executor v, v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: scala.Function;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<scala.Predef$: void assert(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore create_master()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void master_$eq(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_started()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$2: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,scala.Function)>(v, v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
return;
}
public boolean isMaster()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.util.concurrent.atomic.AtomicBoolean v, v;
boolean v, v, v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_started()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_stopped()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.util.concurrent.CountDownLatch stopped_latch()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.CountDownLatch stopped_latch>;
return v;
}
public java.util.concurrent.atomic.AtomicBoolean master_stopped()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_stopped>;
return v;
}
public void stop_master(scala.Function)
{
org.fusesource.hawtdispatch.Task v, v;
java.util.concurrent.Executor v, v;
scala.Function v;
org.fusesource.hawtdispatch.package$ v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_master$2 v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_master$1 v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: scala.Function;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
if v != null goto label;
v = 0;
goto label;
label:
v = 1;
label:
virtualinvoke v.<scala.Predef$: void assert(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_master$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_master$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,scala.Function)>(v, v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_master$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_master$2: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
return;
}
public javax.management.ObjectName objectName()
{
scala.collection.mutable.StringBuilder v, v, v, v, v, v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.lang.String v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
javax.management.ObjectName v, v, v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
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)>("LevelDB[");
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("]");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createPersistenceAdapterName(java.lang.String,java.lang.String)>(v, v);
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
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)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(",view=Replication");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
v = new javax.management.ObjectName;
specialinvoke v.<javax.management.ObjectName: void <init>(java.lang.String)>(v);
return v;
}
public void doStart()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.CountDownLatch master_started_latch()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
return;
}
public void doStop(org.apache.activemq.util.ServiceStopper)
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.util.ServiceStopper v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$doStop$2 v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$doStop$1 v;
boolean v, v;
org.apache.activemq.broker.BrokerService v, v, v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v, v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v, v;
javax.management.ObjectName v;
java.util.concurrent.CountDownLatch v, v, v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.util.ServiceStopper;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
if v == null goto label;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: javax.management.ObjectName objectName()>();
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup zk_group()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void close()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void zk_group_$eq(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(null);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void close()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void zk_client_$eq(org.apache.activemq.leveldb.replicated.groups.ZKClient)>(null);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
if v == null goto label;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$doStop$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$doStop$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,java.util.concurrent.CountDownLatch)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void stop_master(scala.Function)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
if v == null goto label;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$doStop$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$doStop$2: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,java.util.concurrent.CountDownLatch)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void stop_slave(scala.Function)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_started()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.CountDownLatch stopped_latch()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
return;
}
public void start_slave(java.lang.String, scala.Function)
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v, v, v;
org.fusesource.hawtdispatch.Task v;
java.util.concurrent.Executor v;
scala.Function v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_slave$1 v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
v := @parameter: scala.Function;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<scala.Predef$: void assert(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore create_slave()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void slave_$eq(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void connect_$eq(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_slave$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_slave$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,scala.Function)>(v, v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
return;
}
public void stop_slave(scala.Function)
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v, v;
org.fusesource.hawtdispatch.Task v;
java.util.concurrent.Executor v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_slave$1 v;
scala.Function v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: scala.Function;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void slave_$eq(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore)>(null);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_slave$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$stop_slave$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,scala.Function,org.apache.activemq.leveldb.replicated.SlaveLevelDBStore)>(v, v, v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<java.util.concurrent.Executor: void execute(java.lang.Runnable)>(v);
label:
return;
}
public org.apache.activemq.leveldb.replicated.SlaveLevelDBStore create_slave()
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = new org.apache.activemq.leveldb.replicated.SlaveLevelDBStore;
specialinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void configure(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)>(v);
return v;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBStore create_master()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
int v;
java.lang.String v, v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void configure(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void replicas_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String bind()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void bind_$eq(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String sync()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void syncTo_$eq(java.lang.String)>(v);
return v;
}
public void setBrokerName(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void brokerName_$eq(java.lang.String)>(v);
return;
}
public void deleteAllMessages()
{
scala.collection.mutable.WrappedArray v;
java.lang.Object[] v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$deleteAllMessages$1 v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore proxy_target()>();
if v != null goto label;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$deleteAllMessages$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$deleteAllMessages$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore proxy_target()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void deleteAllMessages()>();
label:
return;
}
public void configure(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)
{
org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait v;
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
int v, v, v, v, v, v, v, v;
org.apache.activemq.usage.SystemUsage v;
java.lang.String v, v, v, v, v;
boolean v, v, v;
org.apache.activemq.broker.BrokerService v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void directory_$eq(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexFactory()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexFactory_$eq(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean verifyChecksums()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void verifyChecksums_$eq(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexMaxOpenFiles()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexMaxOpenFiles_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockRestartInterval()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexBlockRestartInterval_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean paranoidChecks()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void paranoidChecks_$eq(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexWriteBufferSize()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexWriteBufferSize_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockSize()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexBlockSize_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexCompression()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexCompression_$eq(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String logCompression()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void logCompression_$eq(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long indexCacheSize()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void indexCacheSize_$eq(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int flushDelay()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void flushDelay_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int asyncBufferSize()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void asyncBufferSize_$eq(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean monitorStats()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void monitorStats_$eq(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String securityToken()>();
interfaceinvoke v.<org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait: void securityToken_$eq(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int failoverProducersAuditDepth()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setFailoverProducersAuditDepth(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int maxFailoverProducersToTrack()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setMaxFailoverProducersToTrack(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String brokerName()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setBrokerName(java.lang.String)>(v);
v = v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.broker.BrokerService brokerService>;
virtualinvoke v.<org.apache.activemq.broker.LockableServiceSupport: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.usage.SystemUsage usageManager()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void setUsageManager(org.apache.activemq.usage.SystemUsage)>(v);
return;
}
public java.lang.String address(int)
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ v;
java.lang.Integer v;
scala.collection.mutable.StringBuilder v, v, v, v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
int v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v := @parameter: int;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String connectUrl()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String hostname()>();
if v != null goto label;
v = <org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$: java.lang.String machine_hostname()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: void hostname_$eq(java.lang.String)>(v);
label:
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)>("tcp://");
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String hostname()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(":");
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(v);
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()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String connectUrl()>();
label:
return v;
}
public long size()
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v, v;
java.lang.String[] v;
long v;
java.io.File v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
scala.Predef$ v;
scala.runtime.LongRef v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$size$1 v;
scala.collection.mutable.ArrayOps v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
if v != null goto label;
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory()>();
v = virtualinvoke v.<java.io.File: java.lang.String[] list()>();
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$size$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$size$1: void <init>(org.apache.activemq.leveldb.replicated.ElectingLevelDBStore,scala.runtime.LongRef)>(v, v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
label:
v = v.<scala.runtime.LongRef: long elem>;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore slave()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: long size()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBStore master()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: long size()>();
label:
return v;
}
public java.lang.String getZkAddress()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress()>();
return v;
}
public java.lang.String getZkPassword()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPassword()>();
return v;
}
public java.lang.String getZkPath()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath()>();
return v;
}
public java.lang.String getZkSessionTimeout()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkSessionTimeout()>();
return v;
}
public java.lang.String getContainer()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String container()>();
return v;
}
public java.lang.String getHostname()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String hostname()>();
return v;
}
public java.lang.String getConnectUrl()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String connectUrl()>();
return v;
}
public java.lang.String getBind()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String bind()>();
return v;
}
public int getWeight()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int weight()>();
return v;
}
public int getReplicas()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas()>();
return v;
}
public java.lang.String getSync()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String sync()>();
return v;
}
public java.lang.String getSecurityToken()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String securityToken()>();
return v;
}
public long getLogSize()
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long logSize()>();
return v;
}
public java.lang.String getIndexFactory()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexFactory()>();
return v;
}
public boolean getVerifyChecksums()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean verifyChecksums()>();
return v;
}
public int getIndexMaxOpenFiles()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexMaxOpenFiles()>();
return v;
}
public int getIndexBlockRestartInterval()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockRestartInterval()>();
return v;
}
public boolean getParanoidChecks()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean paranoidChecks()>();
return v;
}
public int getIndexWriteBufferSize()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexWriteBufferSize()>();
return v;
}
public int getIndexBlockSize()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockSize()>();
return v;
}
public java.lang.String getIndexCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexCompression()>();
return v;
}
public java.lang.String getLogCompression()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String logCompression()>();
return v;
}
public long getIndexCacheSize()
{
long v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long indexCacheSize()>();
return v;
}
public int getFlushDelay()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int flushDelay()>();
return v;
}
public int getAsyncBufferSize()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int asyncBufferSize()>();
return v;
}
public boolean getMonitorStats()
{
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean monitorStats()>();
return v;
}
public int getFailoverProducersAuditDepth()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int failoverProducersAuditDepth()>();
return v;
}
public int getMaxFailoverProducersToTrack()
{
int v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int maxFailoverProducersToTrack()>();
return v;
}
public void <init>()
{
java.util.concurrent.CountDownLatch v, v;
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore v;
java.util.concurrent.atomic.AtomicBoolean v, v;
org.apache.activemq.leveldb.LevelDBStore$ v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.ElectingLevelDBStore;
specialinvoke v.<org.apache.activemq.leveldb.replicated.ProxyLevelDBStore: void <init>()>();
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkAddress> = "127.0.0.1:2181";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkPath> = "/default";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String zkSessionTimeout> = "2s";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String bind> = "tcp://0.0.0.0:61619";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int weight> = 1;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int replicas> = 3;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String sync> = "quorum_mem";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String securityToken> = "";
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore$: java.io.File DEFAULT_DIRECTORY()>();
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.io.File directory> = v;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long logSize> = 104857600L;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexFactory> = "org.fusesource.leveldbjni.JniDBFactory, org.iq.leveldb.impl.Iq80DBFactory";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean verifyChecksums> = 0;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexMaxOpenFiles> = 1000;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockRestartInterval> = 16;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean paranoidChecks> = 0;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexWriteBufferSize> = 6291456;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int indexBlockSize> = 4096;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String indexCompression> = "snappy";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.lang.String logCompression> = "none";
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long indexCacheSize> = 268435456L;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int flushDelay> = 0;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int asyncBufferSize> = 4194304;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: boolean monitorStats> = 0;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int failoverProducersAuditDepth> = 2048;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: int maxFailoverProducersToTrack> = 64;
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: long position> = -1L;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.CountDownLatch master_started_latch> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_started> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.CountDownLatch stopped_latch> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.leveldb.replicated.ElectingLevelDBStore: java.util.concurrent.atomic.AtomicBoolean master_stopped> = v;
return;
}
}