public class org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager extends org.apache.logging.log4j.core.appender.AbstractManager
{
public static final java.lang.String SYS_PROPERTY_ENABLE_SHUTDOWN_HOOK;
public static final java.lang.String SYS_PROPERTY_IO_THREADS;
private static final org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory FACTORY;
private static final org.zeromq.ZContext CONTEXT;
private static final org.apache.logging.log4j.core.util.Cancellable SHUTDOWN_HOOK;
private final org.zeromq.ZMQ$Socket publisher;
private final java.util.List endpoints;
private void <init>(java.lang.String, org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration)
{
byte[] v, v;
org.zeromq.ZMQ$Socket v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.zeromq.ZMonitor$ZEvent v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration v;
org.apache.logging.log4j.Logger v;
org.zeromq.ZMonitor$Event[] v;
org.zeromq.SocketType v;
long v, v, v, v, v, v, v, v, v, v, v, v, v;
org.zeromq.ZContext v, v;
java.util.ArrayList v;
java.lang.String v, v;
boolean v, v, v, v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager v;
java.util.List v, v, v;
org.zeromq.ZMonitor$Event v;
int v, v, v, v;
java.util.Iterator v;
org.zeromq.ZMonitor v;
java.lang.Object v;
v := @this: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager;
v := @parameter: java.lang.String;
v := @parameter: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration;
specialinvoke v.<org.apache.logging.log4j.core.appender.AbstractManager: void <init>(org.apache.logging.log4j.core.LoggerContext,java.lang.String)>(null, v);
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZContext CONTEXT>;
v = <org.zeromq.SocketType: org.zeromq.SocketType PUB>;
v = virtualinvoke v.<org.zeromq.ZContext: org.zeromq.ZMQ$Socket createSocket(org.zeromq.SocketType)>(v);
v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher> = v;
v = new org.zeromq.ZMonitor;
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZContext CONTEXT>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
specialinvoke v.<org.zeromq.ZMonitor: void <init>(org.zeromq.ZContext,org.zeromq.ZMQ$Socket)>(v, v);
v = newarray (org.zeromq.ZMonitor$Event)[1];
v = <org.zeromq.ZMonitor$Event: org.zeromq.ZMonitor$Event LISTENING>;
v[0] = v;
virtualinvoke v.<org.zeromq.ZMonitor: org.zeromq.ZMonitor add(org.zeromq.ZMonitor$Event[])>(v);
virtualinvoke v.<org.zeromq.ZMonitor: org.zeromq.ZMonitor start()>();
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long affinity>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setAffinity(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long backlog>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setBacklog(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: boolean delayAttachOnConnect>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setDelayAttachOnConnect(boolean)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: byte[] identity>;
if v == null goto label;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: byte[] identity>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setIdentity(byte[])>(v);
label:
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: boolean ipv4Only>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setIPv4Only(boolean)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long linger>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setLinger(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long maxMsgSize>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setMaxMsgSize(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long rcvHwm>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setRcvHWM(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long receiveBufferSize>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setReceiveBufferSize(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: int receiveTimeOut>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setReceiveTimeOut(int)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long reconnectIVL>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setReconnectIVL(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long reconnectIVLMax>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setReconnectIVLMax(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long sendBufferSize>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setSendBufferSize(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: int sendTimeOut>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setSendTimeOut(int)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long sndHwm>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setSndHWM(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: int tcpKeepAlive>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setTCPKeepAlive(int)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long tcpKeepAliveCount>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setTCPKeepAliveCount(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long tcpKeepAliveIdle>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setTCPKeepAliveIdle(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: long tcpKeepAliveInterval>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setTCPKeepAliveInterval(long)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: boolean xpubVerbose>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean setXpubVerbose(boolean)>(v);
v = new java.util.ArrayList;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: java.util.List endpoints>;
v = interfaceinvoke v.<java.util.List: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: java.util.List endpoints>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean bind(java.lang.String)>(v);
v = virtualinvoke v.<org.zeromq.ZMonitor: org.zeromq.ZMonitor$ZEvent nextEvent()>();
v = v.<org.zeromq.ZMonitor$ZEvent: java.lang.String address>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: java.util.List endpoints> = v;
virtualinvoke v.<org.zeromq.ZMonitor: void destroy()>();
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.Logger LOGGER>;
interfaceinvoke v.<org.apache.logging.log4j.Logger: void debug(java.lang.String,java.lang.Object)>("Created JeroMqManager with {}", v);
return;
}
public boolean send(byte[])
{
byte[] v;
org.zeromq.ZMQ$Socket v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager v;
boolean v;
v := @this: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager;
v := @parameter: byte[];
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
v = virtualinvoke v.<org.zeromq.ZMQ$Socket: boolean send(byte[])>(v);
return v;
}
protected boolean releaseSub(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.zeromq.ZMQ$Socket v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager v;
long v;
v := @this: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
virtualinvoke v.<org.zeromq.ZMQ$Socket: void close()>();
return 1;
}
org.zeromq.ZMQ$Socket getSocket()
{
org.zeromq.ZMQ$Socket v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager v;
v := @this: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZMQ$Socket publisher>;
return v;
}
public java.util.List getEndpoints()
{
java.util.List v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager v;
v := @this: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager;
v = v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: java.util.List endpoints>;
return v;
}
public static org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager getJeroMqManager(java.lang.String, long, long, boolean, byte[], boolean, long, long, long, long, int, long, long, long, int, long, int, long, long, long, boolean, java.util.List)
{
byte[] v;
org.apache.logging.log4j.core.appender.AbstractManager v;
long v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory v;
int v, v, v;
java.lang.String v;
boolean v, v, v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration v;
java.util.List v;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v := @parameter: boolean;
v := @parameter: byte[];
v := @parameter: boolean;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: int;
v := @parameter: long;
v := @parameter: int;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: boolean;
v := @parameter: java.util.List;
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory FACTORY>;
v = new org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration;
specialinvoke v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqConfiguration: void <init>(long,long,boolean,byte[],boolean,long,long,long,long,int,long,long,long,int,long,int,long,long,long,boolean,java.util.List)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v);
v = staticinvoke <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.core.appender.AbstractManager getManager(java.lang.String,org.apache.logging.log4j.core.appender.ManagerFactory,java.lang.Object)>(v, v, v);
return v;
}
public static org.zeromq.ZMQ$Context getContext()
{
org.zeromq.ZContext v;
org.zeromq.ZMQ$Context v;
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZContext CONTEXT>;
v = virtualinvoke v.<org.zeromq.ZContext: org.zeromq.ZMQ$Context getContext()>();
return v;
}
public static org.zeromq.ZContext getZContext()
{
org.zeromq.ZContext v;
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZContext CONTEXT>;
return v;
}
static void <clinit>()
{
org.apache.logging.log4j.core.util.Cancellable v;
org.zeromq.ZContext v, v;
java.lang.Integer v;
java.lang.Runnable v;
org.apache.logging.log4j.util.PropertiesUtil v, v;
org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory v;
int v;
java.lang.String v;
boolean v, v;
org.apache.logging.log4j.spi.LoggerContextFactory v, v;
org.apache.logging.log4j.Logger v, v;
v = new org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory;
specialinvoke v.<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory: void <init>()>();
<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$JeroMqManagerFactory FACTORY> = v;
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.Logger LOGGER>;
v = staticinvoke <org.zeromq.ZMQ: java.lang.String getVersionString()>();
interfaceinvoke v.<org.apache.logging.log4j.Logger: void trace(java.lang.String,java.lang.Object)>("JeroMqManager using ZMQ version {}", v);
v = staticinvoke <org.apache.logging.log4j.util.PropertiesUtil: org.apache.logging.log4j.util.PropertiesUtil getProperties()>();
v = virtualinvoke v.<org.apache.logging.log4j.util.PropertiesUtil: int getIntegerProperty(java.lang.String,int)>("log4j.jeromq.ioThreads", 1);
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.Logger LOGGER>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void trace(java.lang.String,java.lang.Object)>("JeroMqManager creating ZMQ context with ioThreads = {}", v);
v = new org.zeromq.ZContext;
specialinvoke v.<org.zeromq.ZContext: void <init>(int)>(v);
<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZContext CONTEXT> = v;
v = staticinvoke <org.apache.logging.log4j.util.PropertiesUtil: org.apache.logging.log4j.util.PropertiesUtil getProperties()>();
v = virtualinvoke v.<org.apache.logging.log4j.util.PropertiesUtil: boolean getBooleanProperty(java.lang.String,boolean)>("log4j.jeromq.enableShutdownHook", 1);
if v == 0 goto label;
v = staticinvoke <org.apache.logging.log4j.LogManager: org.apache.logging.log4j.spi.LoggerContextFactory getFactory()>();
v = v instanceof org.apache.logging.log4j.core.util.ShutdownCallbackRegistry;
if v == 0 goto label;
v = staticinvoke <org.apache.logging.log4j.LogManager: org.apache.logging.log4j.spi.LoggerContextFactory getFactory()>();
v = <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.zeromq.ZContext CONTEXT>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager$close__1225: java.lang.Runnable bootstrap$(org.zeromq.ZContext)>(v);
v = interfaceinvoke v.<org.apache.logging.log4j.core.util.ShutdownCallbackRegistry: org.apache.logging.log4j.core.util.Cancellable addShutdownCallback(java.lang.Runnable)>(v);
<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.core.util.Cancellable SHUTDOWN_HOOK> = v;
goto label;
label:
<org.apache.logging.log4j.core.appender.mom.jeromq.JeroMqManager: org.apache.logging.log4j.core.util.Cancellable SHUTDOWN_HOOK> = null;
label:
return;
}
}