class org.apache.cassandra.transport.SimpleClient$ResponseHandler extends io.netty.channel.SimpleChannelInboundHandler<org.apache.cassandra.transport.Message$Response>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.transport.SimpleClient$ResponseHandler
super_class: io.netty.channel.SimpleChannelInboundHandler
{
public final java.util.concurrent.BlockingQueue<org.apache.cassandra.transport.Message$Response> responses;
descriptor: Ljava/util/concurrent/BlockingQueue;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Ljava/util/concurrent/BlockingQueue<Lorg/apache/cassandra/transport/Message$Response;>;
public org.apache.cassandra.transport.SimpleClient$EventHandler eventHandler;
descriptor: Lorg/apache/cassandra/transport/SimpleClient$EventHandler;
flags: (0x0001) ACC_PUBLIC
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.netty.channel.SimpleChannelInboundHandler.<init>:()V
1: aload 0
new java.util.concurrent.SynchronousQueue
dup
iconst_1
invokespecial java.util.concurrent.SynchronousQueue.<init>:(Z)V
putfield org.apache.cassandra.transport.SimpleClient$ResponseHandler.responses:Ljava/util/concurrent/BlockingQueue;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
public void channelRead0(io.netty.channel.ChannelHandlerContext, org.apache.cassandra.transport.Message$Response);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Lorg/apache/cassandra/transport/Message$Response;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
instanceof org.apache.cassandra.transport.messages.EventMessage
ifeq 4
1: aload 0
getfield org.apache.cassandra.transport.SimpleClient$ResponseHandler.eventHandler:Lorg/apache/cassandra/transport/SimpleClient$EventHandler;
ifnull 8
2: aload 0
getfield org.apache.cassandra.transport.SimpleClient$ResponseHandler.eventHandler:Lorg/apache/cassandra/transport/SimpleClient$EventHandler;
aload 2
checkcast org.apache.cassandra.transport.messages.EventMessage
getfield org.apache.cassandra.transport.messages.EventMessage.event:Lorg/apache/cassandra/transport/Event;
invokeinterface org.apache.cassandra.transport.SimpleClient$EventHandler.onEvent:(Lorg/apache/cassandra/transport/Event;)V
3: goto 8
4: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.transport.SimpleClient$ResponseHandler.responses:Ljava/util/concurrent/BlockingQueue;
aload 2
invokeinterface java.util.concurrent.BlockingQueue.put:(Ljava/lang/Object;)V
5: goto 8
6: StackMap locals:
StackMap stack: java.lang.InterruptedException
astore 3
start local 3 7: new java.lang.RuntimeException
dup
aload 3
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 3 8: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
0 9 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 9 2 r Lorg/apache/cassandra/transport/Message$Response;
7 8 3 ie Ljava/lang/InterruptedException;
Exception table:
from to target type
0 5 6 Class java.lang.InterruptedException
MethodParameters:
Name Flags
ctx
r
public void exceptionCaught(io.netty.channel.ChannelHandlerContext, java.lang.Throwable);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
invokeinterface io.netty.channel.ChannelPipeline.last:()Lio/netty/channel/ChannelHandler;
if_acmpne 2
1: getstatic org.apache.cassandra.transport.SimpleClient.logger:Lorg/slf4j/Logger;
ldc "Exception in response"
aload 2
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.netty.channel.ChannelHandlerContext.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelHandlerContext;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
0 4 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 4 2 cause Ljava/lang/Throwable;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
cause
public void channelRead0(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
checkcast org.apache.cassandra.transport.Message$Response
invokevirtual org.apache.cassandra.transport.SimpleClient$ResponseHandler.channelRead0:(Lio/netty/channel/ChannelHandlerContext;Lorg/apache/cassandra/transport/Message$Response;)V
return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
}
Signature: Lio/netty/channel/SimpleChannelInboundHandler<Lorg/apache/cassandra/transport/Message$Response;>;
SourceFile: "SimpleClient.java"
NestHost: org.apache.cassandra.transport.SimpleClient
InnerClasses:
public abstract Sharable = io.netty.channel.ChannelHandler$Sharable of io.netty.channel.ChannelHandler
public abstract Response = org.apache.cassandra.transport.Message$Response of org.apache.cassandra.transport.Message
public abstract EventHandler = org.apache.cassandra.transport.SimpleClient$EventHandler of org.apache.cassandra.transport.SimpleClient
private ResponseHandler = org.apache.cassandra.transport.SimpleClient$ResponseHandler of org.apache.cassandra.transport.SimpleClient
RuntimeVisibleAnnotations:
io.netty.channel.ChannelHandler$Sharable()