public class org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler extends io.netty.channel.SimpleChannelInboundHandler
{
private static final org.slf4j.Logger LOGGER;
private final java.util.concurrent.BlockingQueue events;
private final org.apache.nifi.processors.standard.relp.frame.RELPEncoder encoder;
public void <init>(java.util.concurrent.BlockingQueue, java.nio.charset.Charset)
{
java.nio.charset.Charset v;
org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler v;
org.apache.nifi.processors.standard.relp.frame.RELPEncoder v;
java.util.concurrent.BlockingQueue v;
v := @this: org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler;
v := @parameter: java.util.concurrent.BlockingQueue;
v := @parameter: java.nio.charset.Charset;
specialinvoke v.<io.netty.channel.SimpleChannelInboundHandler: void <init>()>();
v.<org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: java.util.concurrent.BlockingQueue events> = v;
v = new org.apache.nifi.processors.standard.relp.frame.RELPEncoder;
specialinvoke v.<org.apache.nifi.processors.standard.relp.frame.RELPEncoder: void <init>(java.nio.charset.Charset)>(v);
v.<org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.apache.nifi.processors.standard.relp.frame.RELPEncoder encoder> = v;
return;
}
protected void channelRead0(io.netty.channel.ChannelHandlerContext, org.apache.nifi.processors.standard.relp.event.RELPMessage)
{
byte[] v, v, v;
org.apache.nifi.processors.standard.relp.frame.RELPEncoder v, v;
long v, v, v, v;
java.lang.Integer v;
io.netty.channel.ChannelHandlerContext v;
io.netty.buffer.ByteBuf v, v;
java.lang.Long v, v;
org.apache.nifi.processors.standard.relp.response.RELPResponse v, v;
int v;
java.lang.String v, v, v;
boolean v;
org.apache.nifi.processors.standard.relp.response.RELPChannelResponse v, v;
org.slf4j.Logger v, v, v;
org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler v;
java.util.concurrent.BlockingQueue v;
org.apache.nifi.processors.standard.relp.event.RELPMessage v;
v := @this: org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler;
v := @parameter: io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.nifi.processors.standard.relp.event.RELPMessage;
v = <org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.slf4j.Logger LOGGER>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: byte[] getMessage()>();
v = lengthof v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: java.lang.String getSender()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("RELP Message Received Length [{}] Remote Address [{}] ", v, v);
v = v.<org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: java.util.concurrent.BlockingQueue events>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean offer(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.slf4j.Logger LOGGER>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: java.lang.String getSender()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: long getTxnr()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Event Queued: RELP Message Sender [{}] Transaction Number [{}]", v, v);
v = new org.apache.nifi.processors.standard.relp.response.RELPChannelResponse;
v = v.<org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.apache.nifi.processors.standard.relp.frame.RELPEncoder encoder>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: long getTxnr()>();
v = staticinvoke <org.apache.nifi.processors.standard.relp.response.RELPResponse: org.apache.nifi.processors.standard.relp.response.RELPResponse ok(long)>(v);
specialinvoke v.<org.apache.nifi.processors.standard.relp.response.RELPChannelResponse: void <init>(org.apache.nifi.processors.standard.relp.frame.RELPEncoder,org.apache.nifi.processors.standard.relp.response.RELPResponse)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.response.RELPChannelResponse: byte[] toByteArray()>();
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf wrappedBuffer(byte[])>(v);
interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.slf4j.Logger LOGGER>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: java.lang.String getSender()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: long getTxnr()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Event Queue Full: Failed RELP Message Sender [{}] Transaction Number [{}]", v, v);
v = new org.apache.nifi.processors.standard.relp.response.RELPChannelResponse;
v = v.<org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.apache.nifi.processors.standard.relp.frame.RELPEncoder encoder>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.event.RELPMessage: long getTxnr()>();
v = staticinvoke <org.apache.nifi.processors.standard.relp.response.RELPResponse: org.apache.nifi.processors.standard.relp.response.RELPResponse serverFullError(long)>(v);
specialinvoke v.<org.apache.nifi.processors.standard.relp.response.RELPChannelResponse: void <init>(org.apache.nifi.processors.standard.relp.frame.RELPEncoder,org.apache.nifi.processors.standard.relp.response.RELPResponse)>(v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.relp.response.RELPChannelResponse: byte[] toByteArray()>();
v = staticinvoke <io.netty.buffer.Unpooled: io.netty.buffer.ByteBuf wrappedBuffer(byte[])>(v);
interfaceinvoke v.<io.netty.channel.ChannelHandlerContext: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/relp/frame/RELPMessageChannelHandler;");
<org.apache.nifi.processors.standard.relp.frame.RELPMessageChannelHandler: org.slf4j.Logger LOGGER> = v;
return;
}
}