https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
public class org.apache.cassandra.transport.SimpleClient implements java.io.Closeable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.transport.SimpleClient
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  public final java.lang.String host;
    descriptor: Ljava/lang/String;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final int port;
    descriptor: I
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  private final org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions;
    descriptor: Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  protected final org.apache.cassandra.transport.SimpleClient$ResponseHandler responseHandler;
    descriptor: Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final org.apache.cassandra.transport.Connection$Tracker tracker;
    descriptor: Lorg/apache/cassandra/transport/Connection$Tracker;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final org.apache.cassandra.transport.ProtocolVersion version;
    descriptor: Lorg/apache/cassandra/transport/ProtocolVersion;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected org.apache.cassandra.transport.Connection connection;
    descriptor: Lorg/apache/cassandra/transport/Connection;
    flags: (0x0004) ACC_PROTECTED

  protected io.netty.bootstrap.Bootstrap bootstrap;
    descriptor: Lio/netty/bootstrap/Bootstrap;
    flags: (0x0004) ACC_PROTECTED

  protected io.netty.channel.Channel channel;
    descriptor: Lio/netty/channel/Channel;
    flags: (0x0004) ACC_PROTECTED

  protected io.netty.channel.ChannelFuture lastWriteFuture;
    descriptor: Lio/netty/channel/ChannelFuture;
    flags: (0x0004) ACC_PROTECTED

  private final org.apache.cassandra.transport.Connection$Factory connectionFactory;
    descriptor: Lorg/apache/cassandra/transport/Connection$Factory;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private static final org.apache.cassandra.transport.Message$ProtocolDecoder messageDecoder;
    descriptor: Lorg/apache/cassandra/transport/Message$ProtocolDecoder;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final org.apache.cassandra.transport.Message$ProtocolEncoder messageEncoder;
    descriptor: Lorg/apache/cassandra/transport/Message$ProtocolEncoder;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final org.apache.cassandra.transport.Frame$Decompressor frameDecompressor;
    descriptor: Lorg/apache/cassandra/transport/Frame$Decompressor;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final org.apache.cassandra.transport.Frame$Compressor frameCompressor;
    descriptor: Lorg/apache/cassandra/transport/Frame$Compressor;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final org.apache.cassandra.transport.Frame$Encoder frameEncoder;
    descriptor: Lorg/apache/cassandra/transport/Frame$Encoder;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 64
            ldc Lorg/apache/cassandra/transport/SimpleClient;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.transport.SimpleClient.$assertionsDisabled:Z
         3: .line 68
            new io.netty.util.internal.logging.Slf4JLoggerFactory
            dup
            invokespecial io.netty.util.internal.logging.Slf4JLoggerFactory.<init>:()V
            invokestatic io.netty.util.internal.logging.InternalLoggerFactory.setDefaultFactory:(Lio/netty/util/internal/logging/InternalLoggerFactory;)V
         4: .line 71
            ldc Lorg/apache/cassandra/transport/SimpleClient;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.transport.SimpleClient.logger:Lorg/slf4j/Logger;
         5: .line 261
            new org.apache.cassandra.transport.Message$ProtocolDecoder
            dup
            invokespecial org.apache.cassandra.transport.Message$ProtocolDecoder.<init>:()V
            putstatic org.apache.cassandra.transport.SimpleClient.messageDecoder:Lorg/apache/cassandra/transport/Message$ProtocolDecoder;
         6: .line 262
            new org.apache.cassandra.transport.Message$ProtocolEncoder
            dup
            getstatic org.apache.cassandra.transport.ProtocolVersionLimit.SERVER_DEFAULT:Lorg/apache/cassandra/transport/ProtocolVersionLimit;
            invokespecial org.apache.cassandra.transport.Message$ProtocolEncoder.<init>:(Lorg/apache/cassandra/transport/ProtocolVersionLimit;)V
            putstatic org.apache.cassandra.transport.SimpleClient.messageEncoder:Lorg/apache/cassandra/transport/Message$ProtocolEncoder;
         7: .line 263
            new org.apache.cassandra.transport.Frame$Decompressor
            dup
            invokespecial org.apache.cassandra.transport.Frame$Decompressor.<init>:()V
            putstatic org.apache.cassandra.transport.SimpleClient.frameDecompressor:Lorg/apache/cassandra/transport/Frame$Decompressor;
         8: .line 264
            new org.apache.cassandra.transport.Frame$Compressor
            dup
            invokespecial org.apache.cassandra.transport.Frame$Compressor.<init>:()V
            putstatic org.apache.cassandra.transport.SimpleClient.frameCompressor:Lorg/apache/cassandra/transport/Frame$Compressor;
         9: .line 265
            new org.apache.cassandra.transport.Frame$Encoder
            dup
            invokespecial org.apache.cassandra.transport.Frame$Encoder.<init>:()V
            putstatic org.apache.cassandra.transport.SimpleClient.frameEncoder:Lorg/apache/cassandra/transport/Frame$Encoder;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.lang.String, int, org.apache.cassandra.transport.ProtocolVersion, org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions);
    descriptor: (Ljava/lang/String;ILorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=5
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String host
        start local 2 // int port
        start local 3 // org.apache.cassandra.transport.ProtocolVersion version
        start local 4 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions
         0: .line 95
            aload 0 /* this */
            aload 1 /* host */
            iload 2 /* port */
            aload 3 /* version */
            iconst_0
            aload 4 /* encryptionOptions */
            invokespecial org.apache.cassandra.transport.SimpleClient.<init>:(Ljava/lang/String;ILorg/apache/cassandra/transport/ProtocolVersion;ZLorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
         1: .line 96
            return
        end local 4 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions
        end local 3 // org.apache.cassandra.transport.ProtocolVersion version
        end local 2 // int port
        end local 1 // java.lang.String host
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lorg/apache/cassandra/transport/SimpleClient;
            0    2     1               host  Ljava/lang/String;
            0    2     2               port  I
            0    2     3            version  Lorg/apache/cassandra/transport/ProtocolVersion;
            0    2     4  encryptionOptions  Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
    MethodParameters:
                   Name  Flags
      host               
      port               
      version            
      encryptionOptions  

  public void <init>(java.lang.String, int, org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions);
    descriptor: (Ljava/lang/String;ILorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String host
        start local 2 // int port
        start local 3 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions
         0: .line 100
            aload 0 /* this */
            aload 1 /* host */
            iload 2 /* port */
            getstatic org.apache.cassandra.transport.ProtocolVersion.CURRENT:Lorg/apache/cassandra/transport/ProtocolVersion;
            aload 3 /* encryptionOptions */
            invokespecial org.apache.cassandra.transport.SimpleClient.<init>:(Ljava/lang/String;ILorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
         1: .line 101
            return
        end local 3 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions
        end local 2 // int port
        end local 1 // java.lang.String host
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lorg/apache/cassandra/transport/SimpleClient;
            0    2     1               host  Ljava/lang/String;
            0    2     2               port  I
            0    2     3  encryptionOptions  Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
    MethodParameters:
                   Name  Flags
      host               
      port               
      encryptionOptions  

  public void <init>(java.lang.String, int, org.apache.cassandra.transport.ProtocolVersion);
    descriptor: (Ljava/lang/String;ILorg/apache/cassandra/transport/ProtocolVersion;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String host
        start local 2 // int port
        start local 3 // org.apache.cassandra.transport.ProtocolVersion version
         0: .line 105
            aload 0 /* this */
            aload 1 /* host */
            iload 2 /* port */
            aload 3 /* version */
            new org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions
            dup
            invokespecial org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions.<init>:()V
            invokespecial org.apache.cassandra.transport.SimpleClient.<init>:(Ljava/lang/String;ILorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
         1: .line 106
            return
        end local 3 // org.apache.cassandra.transport.ProtocolVersion version
        end local 2 // int port
        end local 1 // java.lang.String host
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lorg/apache/cassandra/transport/SimpleClient;
            0    2     1     host  Ljava/lang/String;
            0    2     2     port  I
            0    2     3  version  Lorg/apache/cassandra/transport/ProtocolVersion;
    MethodParameters:
         Name  Flags
      host     
      port     
      version  

  public void <init>(java.lang.String, int, org.apache.cassandra.transport.ProtocolVersion, boolean, org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions);
    descriptor: (Ljava/lang/String;ILorg/apache/cassandra/transport/ProtocolVersion;ZLorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=6, args_size=6
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String host
        start local 2 // int port
        start local 3 // org.apache.cassandra.transport.ProtocolVersion version
        start local 4 // boolean useBeta
        start local 5 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions
         0: .line 108
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 76
            aload 0 /* this */
            new org.apache.cassandra.transport.SimpleClient$ResponseHandler
            dup
            invokespecial org.apache.cassandra.transport.SimpleClient$ResponseHandler.<init>:()V
            putfield org.apache.cassandra.transport.SimpleClient.responseHandler:Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
         2: .line 77
            aload 0 /* this */
            new org.apache.cassandra.transport.SimpleClient$ConnectionTracker
            dup
            invokespecial org.apache.cassandra.transport.SimpleClient$ConnectionTracker.<init>:()V
            putfield org.apache.cassandra.transport.SimpleClient.tracker:Lorg/apache/cassandra/transport/Connection$Tracker;
         3: .line 85
            aload 0 /* this */
            new org.apache.cassandra.transport.SimpleClient$1
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.transport.SimpleClient$1.<init>:(Lorg/apache/cassandra/transport/SimpleClient;)V
            putfield org.apache.cassandra.transport.SimpleClient.connectionFactory:Lorg/apache/cassandra/transport/Connection$Factory;
         4: .line 110
            aload 0 /* this */
            aload 1 /* host */
            putfield org.apache.cassandra.transport.SimpleClient.host:Ljava/lang/String;
         5: .line 111
            aload 0 /* this */
            iload 2 /* port */
            putfield org.apache.cassandra.transport.SimpleClient.port:I
         6: .line 112
            aload 3 /* version */
            invokevirtual org.apache.cassandra.transport.ProtocolVersion.isBeta:()Z
            ifeq 8
            iload 4 /* useBeta */
            ifne 8
         7: .line 113
            new java.lang.IllegalArgumentException
            dup
            ldc "Beta version of server used (%s), but USE_BETA flag is not set"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 3 /* version */
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         8: .line 115
      StackMap locals: org.apache.cassandra.transport.SimpleClient java.lang.String int org.apache.cassandra.transport.ProtocolVersion int org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions
      StackMap stack:
            aload 0 /* this */
            aload 3 /* version */
            putfield org.apache.cassandra.transport.SimpleClient.version:Lorg/apache/cassandra/transport/ProtocolVersion;
         9: .line 116
            aload 0 /* this */
            aload 5 /* encryptionOptions */
            putfield org.apache.cassandra.transport.SimpleClient.encryptionOptions:Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
        10: .line 117
            return
        end local 5 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions encryptionOptions
        end local 4 // boolean useBeta
        end local 3 // org.apache.cassandra.transport.ProtocolVersion version
        end local 2 // int port
        end local 1 // java.lang.String host
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   11     0               this  Lorg/apache/cassandra/transport/SimpleClient;
            0   11     1               host  Ljava/lang/String;
            0   11     2               port  I
            0   11     3            version  Lorg/apache/cassandra/transport/ProtocolVersion;
            0   11     4            useBeta  Z
            0   11     5  encryptionOptions  Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
    MethodParameters:
                   Name  Flags
      host               
      port               
      version            
      useBeta            
      encryptionOptions  

  public void <init>(java.lang.String, int);
    descriptor: (Ljava/lang/String;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String host
        start local 2 // int port
         0: .line 121
            aload 0 /* this */
            aload 1 /* host */
            iload 2 /* port */
            new org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions
            dup
            invokespecial org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions.<init>:()V
            invokespecial org.apache.cassandra.transport.SimpleClient.<init>:(Ljava/lang/String;ILorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)V
         1: .line 122
            return
        end local 2 // int port
        end local 1 // java.lang.String host
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/transport/SimpleClient;
            0    2     1  host  Ljava/lang/String;
            0    2     2  port  I
    MethodParameters:
      Name  Flags
      host  
      port  

  public void connect(boolean);
    descriptor: (Z)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // boolean useCompression
         0: .line 126
            aload 0 /* this */
            iload 1 /* useCompression */
            iconst_0
            invokevirtual org.apache.cassandra.transport.SimpleClient.connect:(ZZ)V
         1: .line 127
            return
        end local 1 // boolean useCompression
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    2     0            this  Lorg/apache/cassandra/transport/SimpleClient;
            0    2     1  useCompression  Z
    Exceptions:
      throws java.io.IOException
    MethodParameters:
                Name  Flags
      useCompression  

  public void connect(boolean, boolean);
    descriptor: (ZZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // boolean useCompression
        start local 2 // boolean throwOnOverload
         0: .line 131
            aload 0 /* this */
            invokevirtual org.apache.cassandra.transport.SimpleClient.establishConnection:()V
         1: .line 133
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 3 /* options */
        start local 3 // java.util.Map options
         2: .line 134
            aload 3 /* options */
            ldc "CQL_VERSION"
            ldc "3.0.0"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 136
            iload 2 /* throwOnOverload */
            ifeq 5
         4: .line 137
            aload 3 /* options */
            ldc "THROW_ON_OVERLOAD"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 138
      StackMap locals: java.util.Map
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.connection:Lorg/apache/cassandra/transport/Connection;
            iload 2 /* throwOnOverload */
            invokevirtual org.apache.cassandra.transport.Connection.setThrowOnOverload:(Z)V
         6: .line 140
            iload 1 /* useCompression */
            ifeq 9
         7: .line 142
            aload 3 /* options */
            ldc "COMPRESSION"
            ldc "snappy"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         8: .line 143
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.connection:Lorg/apache/cassandra/transport/Connection;
            getstatic org.apache.cassandra.transport.FrameCompressor$SnappyCompressor.instance:Lorg/apache/cassandra/transport/FrameCompressor$SnappyCompressor;
            invokevirtual org.apache.cassandra.transport.Connection.setCompressor:(Lorg/apache/cassandra/transport/FrameCompressor;)V
         9: .line 145
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new org.apache.cassandra.transport.messages.StartupMessage
            dup
            aload 3 /* options */
            invokespecial org.apache.cassandra.transport.messages.StartupMessage.<init>:(Ljava/util/Map;)V
            invokevirtual org.apache.cassandra.transport.SimpleClient.execute:(Lorg/apache/cassandra/transport/Message$Request;)Lorg/apache/cassandra/transport/Message$Response;
            pop
        10: .line 146
            return
        end local 3 // java.util.Map options
        end local 2 // boolean throwOnOverload
        end local 1 // boolean useCompression
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   11     0             this  Lorg/apache/cassandra/transport/SimpleClient;
            0   11     1   useCompression  Z
            0   11     2  throwOnOverload  Z
            2   11     3          options  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
                 Name  Flags
      useCompression   
      throwOnOverload  

  public void setEventHandler(org.apache.cassandra.transport.SimpleClient$EventHandler);
    descriptor: (Lorg/apache/cassandra/transport/SimpleClient$EventHandler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // org.apache.cassandra.transport.SimpleClient$EventHandler eventHandler
         0: .line 150
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.responseHandler:Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
            aload 1 /* eventHandler */
            putfield org.apache.cassandra.transport.SimpleClient$ResponseHandler.eventHandler:Lorg/apache/cassandra/transport/SimpleClient$EventHandler;
         1: .line 151
            return
        end local 1 // org.apache.cassandra.transport.SimpleClient$EventHandler eventHandler
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    2     0          this  Lorg/apache/cassandra/transport/SimpleClient;
            0    2     1  eventHandler  Lorg/apache/cassandra/transport/SimpleClient$EventHandler;
    MethodParameters:
              Name  Flags
      eventHandler  

  protected void establishConnection();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=2, args_size=1
        start local 0 // org.apache.cassandra.transport.SimpleClient this
         0: .line 156
            aload 0 /* this */
            new io.netty.bootstrap.Bootstrap
            dup
            invokespecial io.netty.bootstrap.Bootstrap.<init>:()V
         1: .line 157
            new io.netty.channel.nio.NioEventLoopGroup
            dup
            invokespecial io.netty.channel.nio.NioEventLoopGroup.<init>:()V
            invokevirtual io.netty.bootstrap.Bootstrap.group:(Lio/netty/channel/EventLoopGroup;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
         2: .line 158
            ldc Lio/netty/channel/socket/nio/NioSocketChannel;
            invokevirtual io.netty.bootstrap.Bootstrap.channel:(Ljava/lang/Class;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
         3: .line 159
            getstatic io.netty.channel.ChannelOption.TCP_NODELAY:Lio/netty/channel/ChannelOption;
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.netty.bootstrap.Bootstrap.option:(Lio/netty/channel/ChannelOption;Ljava/lang/Object;)Lio/netty/bootstrap/AbstractBootstrap;
            checkcast io.netty.bootstrap.Bootstrap
         4: .line 156
            putfield org.apache.cassandra.transport.SimpleClient.bootstrap:Lio/netty/bootstrap/Bootstrap;
         5: .line 162
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.encryptionOptions:Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
            getfield org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions.enabled:Z
            ifeq 8
         6: .line 164
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.bootstrap:Lio/netty/bootstrap/Bootstrap;
            new org.apache.cassandra.transport.SimpleClient$SecureInitializer
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.transport.SimpleClient$SecureInitializer.<init>:(Lorg/apache/cassandra/transport/SimpleClient;)V
            invokevirtual io.netty.bootstrap.Bootstrap.handler:(Lio/netty/channel/ChannelHandler;)Lio/netty/bootstrap/AbstractBootstrap;
            pop
         7: .line 165
            goto 9
         8: .line 168
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.bootstrap:Lio/netty/bootstrap/Bootstrap;
            new org.apache.cassandra.transport.SimpleClient$Initializer
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.transport.SimpleClient$Initializer.<init>:(Lorg/apache/cassandra/transport/SimpleClient;)V
            invokevirtual io.netty.bootstrap.Bootstrap.handler:(Lio/netty/channel/ChannelHandler;)Lio/netty/bootstrap/AbstractBootstrap;
            pop
         9: .line 170
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.bootstrap:Lio/netty/bootstrap/Bootstrap;
            new java.net.InetSocketAddress
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.host:Ljava/lang/String;
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.port:I
            invokespecial java.net.InetSocketAddress.<init>:(Ljava/lang/String;I)V
            invokevirtual io.netty.bootstrap.Bootstrap.connect:(Ljava/net/SocketAddress;)Lio/netty/channel/ChannelFuture;
            astore 1 /* future */
        start local 1 // io.netty.channel.ChannelFuture future
        10: .line 173
            aload 0 /* this */
            aload 1 /* future */
            invokeinterface io.netty.channel.ChannelFuture.awaitUninterruptibly:()Lio/netty/channel/ChannelFuture;
            invokeinterface io.netty.channel.ChannelFuture.channel:()Lio/netty/channel/Channel;
            putfield org.apache.cassandra.transport.SimpleClient.channel:Lio/netty/channel/Channel;
        11: .line 174
            aload 1 /* future */
            invokeinterface io.netty.channel.ChannelFuture.isSuccess:()Z
            ifne 14
        12: .line 176
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.bootstrap:Lio/netty/bootstrap/Bootstrap;
            invokevirtual io.netty.bootstrap.Bootstrap.group:()Lio/netty/channel/EventLoopGroup;
            invokeinterface io.netty.channel.EventLoopGroup.shutdownGracefully:()Lio/netty/util/concurrent/Future;
            pop
        13: .line 177
            new java.io.IOException
            dup
            ldc "Connection Error"
            aload 1 /* future */
            invokeinterface io.netty.channel.ChannelFuture.cause:()Ljava/lang/Throwable;
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        14: .line 179
      StackMap locals: io.netty.channel.ChannelFuture
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelFuture future
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   15     0    this  Lorg/apache/cassandra/transport/SimpleClient;
           10   15     1  future  Lio/netty/channel/ChannelFuture;
    Exceptions:
      throws java.io.IOException

  public void login(java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Ljava/util/Map;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.util.Map credentials
         0: .line 183
            new org.apache.cassandra.transport.messages.CredentialsMessage
            dup
            invokespecial org.apache.cassandra.transport.messages.CredentialsMessage.<init>:()V
            astore 2 /* msg */
        start local 2 // org.apache.cassandra.transport.messages.CredentialsMessage msg
         1: .line 184
            aload 2 /* msg */
            getfield org.apache.cassandra.transport.messages.CredentialsMessage.credentials:Ljava/util/Map;
            aload 1 /* credentials */
            invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
         2: .line 185
            aload 0 /* this */
            aload 2 /* msg */
            invokevirtual org.apache.cassandra.transport.SimpleClient.execute:(Lorg/apache/cassandra/transport/Message$Request;)Lorg/apache/cassandra/transport/Message$Response;
            pop
         3: .line 186
            return
        end local 2 // org.apache.cassandra.transport.messages.CredentialsMessage msg
        end local 1 // java.util.Map credentials
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lorg/apache/cassandra/transport/SimpleClient;
            0    4     1  credentials  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            1    4     2          msg  Lorg/apache/cassandra/transport/messages/CredentialsMessage;
    Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
             Name  Flags
      credentials  

  public org.apache.cassandra.transport.messages.ResultMessage execute(java.lang.String, org.apache.cassandra.db.ConsistencyLevel);
    descriptor: (Ljava/lang/String;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/transport/messages/ResultMessage;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String query
        start local 2 // org.apache.cassandra.db.ConsistencyLevel consistency
         0: .line 190
            aload 0 /* this */
            aload 1 /* query */
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            aload 2 /* consistency */
            invokevirtual org.apache.cassandra.transport.SimpleClient.execute:(Ljava/lang/String;Ljava/util/List;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/transport/messages/ResultMessage;
            areturn
        end local 2 // org.apache.cassandra.db.ConsistencyLevel consistency
        end local 1 // java.lang.String query
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0         this  Lorg/apache/cassandra/transport/SimpleClient;
            0    1     1        query  Ljava/lang/String;
            0    1     2  consistency  Lorg/apache/cassandra/db/ConsistencyLevel;
    MethodParameters:
             Name  Flags
      query        
      consistency  

  public org.apache.cassandra.transport.messages.ResultMessage execute(java.lang.String, java.util.List<java.nio.ByteBuffer>, org.apache.cassandra.db.ConsistencyLevel);
    descriptor: (Ljava/lang/String;Ljava/util/List;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/transport/messages/ResultMessage;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String query
        start local 2 // java.util.List values
        start local 3 // org.apache.cassandra.db.ConsistencyLevel consistencyLevel
         0: .line 195
            aload 0 /* this */
            new org.apache.cassandra.transport.messages.QueryMessage
            dup
            aload 1 /* query */
            aload 3 /* consistencyLevel */
            aload 2 /* values */
            invokestatic org.apache.cassandra.cql3.QueryOptions.forInternalCalls:(Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/util/List;)Lorg/apache/cassandra/cql3/QueryOptions;
            invokespecial org.apache.cassandra.transport.messages.QueryMessage.<init>:(Ljava/lang/String;Lorg/apache/cassandra/cql3/QueryOptions;)V
            invokevirtual org.apache.cassandra.transport.SimpleClient.execute:(Lorg/apache/cassandra/transport/Message$Request;)Lorg/apache/cassandra/transport/Message$Response;
            astore 4 /* msg */
        start local 4 // org.apache.cassandra.transport.Message$Response msg
         1: .line 196
            getstatic org.apache.cassandra.transport.SimpleClient.$assertionsDisabled:Z
            ifne 2
            aload 4 /* msg */
            instanceof org.apache.cassandra.transport.messages.ResultMessage
            ifne 2
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         2: .line 197
      StackMap locals: org.apache.cassandra.transport.Message$Response
      StackMap stack:
            aload 4 /* msg */
            checkcast org.apache.cassandra.transport.messages.ResultMessage
            areturn
        end local 4 // org.apache.cassandra.transport.Message$Response msg
        end local 3 // org.apache.cassandra.db.ConsistencyLevel consistencyLevel
        end local 2 // java.util.List values
        end local 1 // java.lang.String query
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    3     0              this  Lorg/apache/cassandra/transport/SimpleClient;
            0    3     1             query  Ljava/lang/String;
            0    3     2            values  Ljava/util/List<Ljava/nio/ByteBuffer;>;
            0    3     3  consistencyLevel  Lorg/apache/cassandra/db/ConsistencyLevel;
            1    3     4               msg  Lorg/apache/cassandra/transport/Message$Response;
    Signature: (Ljava/lang/String;Ljava/util/List<Ljava/nio/ByteBuffer;>;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/transport/messages/ResultMessage;
    MethodParameters:
                  Name  Flags
      query             
      values            
      consistencyLevel  

  public org.apache.cassandra.transport.messages.ResultMessage$Prepared prepare(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/transport/messages/ResultMessage$Prepared;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // java.lang.String query
         0: .line 202
            aload 0 /* this */
            new org.apache.cassandra.transport.messages.PrepareMessage
            dup
            aload 1 /* query */
            invokespecial org.apache.cassandra.transport.messages.PrepareMessage.<init>:(Ljava/lang/String;)V
            invokevirtual org.apache.cassandra.transport.SimpleClient.execute:(Lorg/apache/cassandra/transport/Message$Request;)Lorg/apache/cassandra/transport/Message$Response;
            astore 2 /* msg */
        start local 2 // org.apache.cassandra.transport.Message$Response msg
         1: .line 203
            getstatic org.apache.cassandra.transport.SimpleClient.$assertionsDisabled:Z
            ifne 2
            aload 2 /* msg */
            instanceof org.apache.cassandra.transport.messages.ResultMessage$Prepared
            ifne 2
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         2: .line 204
      StackMap locals: org.apache.cassandra.transport.Message$Response
      StackMap stack:
            aload 2 /* msg */
            checkcast org.apache.cassandra.transport.messages.ResultMessage$Prepared
            areturn
        end local 2 // org.apache.cassandra.transport.Message$Response msg
        end local 1 // java.lang.String query
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    3     0   this  Lorg/apache/cassandra/transport/SimpleClient;
            0    3     1  query  Ljava/lang/String;
            1    3     2    msg  Lorg/apache/cassandra/transport/Message$Response;
    MethodParameters:
       Name  Flags
      query  

  public org.apache.cassandra.transport.messages.ResultMessage executePrepared(byte[], java.util.List<java.nio.ByteBuffer>, org.apache.cassandra.db.ConsistencyLevel);
    descriptor: ([BLjava/util/List;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/transport/messages/ResultMessage;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // byte[] statementId
        start local 2 // java.util.List values
        start local 3 // org.apache.cassandra.db.ConsistencyLevel consistency
         0: .line 209
            aload 0 /* this */
            new org.apache.cassandra.transport.messages.ExecuteMessage
            dup
            aload 1 /* statementId */
            invokestatic org.apache.cassandra.utils.MD5Digest.wrap:([B)Lorg/apache/cassandra/utils/MD5Digest;
            aload 3 /* consistency */
            aload 2 /* values */
            invokestatic org.apache.cassandra.cql3.QueryOptions.forInternalCalls:(Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/util/List;)Lorg/apache/cassandra/cql3/QueryOptions;
            invokespecial org.apache.cassandra.transport.messages.ExecuteMessage.<init>:(Lorg/apache/cassandra/utils/MD5Digest;Lorg/apache/cassandra/cql3/QueryOptions;)V
            invokevirtual org.apache.cassandra.transport.SimpleClient.execute:(Lorg/apache/cassandra/transport/Message$Request;)Lorg/apache/cassandra/transport/Message$Response;
            astore 4 /* msg */
        start local 4 // org.apache.cassandra.transport.Message$Response msg
         1: .line 210
            getstatic org.apache.cassandra.transport.SimpleClient.$assertionsDisabled:Z
            ifne 2
            aload 4 /* msg */
            instanceof org.apache.cassandra.transport.messages.ResultMessage
            ifne 2
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         2: .line 211
      StackMap locals: org.apache.cassandra.transport.Message$Response
      StackMap stack:
            aload 4 /* msg */
            checkcast org.apache.cassandra.transport.messages.ResultMessage
            areturn
        end local 4 // org.apache.cassandra.transport.Message$Response msg
        end local 3 // org.apache.cassandra.db.ConsistencyLevel consistency
        end local 2 // java.util.List values
        end local 1 // byte[] statementId
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    3     0         this  Lorg/apache/cassandra/transport/SimpleClient;
            0    3     1  statementId  [B
            0    3     2       values  Ljava/util/List<Ljava/nio/ByteBuffer;>;
            0    3     3  consistency  Lorg/apache/cassandra/db/ConsistencyLevel;
            1    3     4          msg  Lorg/apache/cassandra/transport/Message$Response;
    Signature: ([BLjava/util/List<Ljava/nio/ByteBuffer;>;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/transport/messages/ResultMessage;
    MethodParameters:
             Name  Flags
      statementId  
      values       
      consistency  

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.transport.SimpleClient this
         0: .line 217
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.lastWriteFuture:Lio/netty/channel/ChannelFuture;
            ifnull 2
         1: .line 218
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.lastWriteFuture:Lio/netty/channel/ChannelFuture;
            invokeinterface io.netty.channel.ChannelFuture.awaitUninterruptibly:()Lio/netty/channel/ChannelFuture;
            pop
         2: .line 222
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.channel:Lio/netty/channel/Channel;
            invokeinterface io.netty.channel.Channel.close:()Lio/netty/channel/ChannelFuture;
            invokeinterface io.netty.channel.ChannelFuture.awaitUninterruptibly:()Lio/netty/channel/ChannelFuture;
            pop
         3: .line 225
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.bootstrap:Lio/netty/bootstrap/Bootstrap;
            invokevirtual io.netty.bootstrap.Bootstrap.group:()Lio/netty/channel/EventLoopGroup;
            invokeinterface io.netty.channel.EventLoopGroup.shutdownGracefully:()Lio/netty/util/concurrent/Future;
            pop
         4: .line 226
            return
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/apache/cassandra/transport/SimpleClient;

  public org.apache.cassandra.transport.Message$Response execute(org.apache.cassandra.transport.Message$Request);
    descriptor: (Lorg/apache/cassandra/transport/Message$Request;)Lorg/apache/cassandra/transport/Message$Response;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // org.apache.cassandra.transport.SimpleClient this
        start local 1 // org.apache.cassandra.transport.Message$Request request
         0: .line 232
            aload 1 /* request */
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.connection:Lorg/apache/cassandra/transport/Connection;
            invokevirtual org.apache.cassandra.transport.Message$Request.attach:(Lorg/apache/cassandra/transport/Connection;)V
         1: .line 233
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.channel:Lio/netty/channel/Channel;
            aload 1 /* request */
            invokeinterface io.netty.channel.Channel.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
            putfield org.apache.cassandra.transport.SimpleClient.lastWriteFuture:Lio/netty/channel/ChannelFuture;
         2: .line 234
            aload 0 /* this */
            getfield org.apache.cassandra.transport.SimpleClient.responseHandler:Lorg/apache/cassandra/transport/SimpleClient$ResponseHandler;
            getfield org.apache.cassandra.transport.SimpleClient$ResponseHandler.responses:Ljava/util/concurrent/BlockingQueue;
            invokeinterface java.util.concurrent.BlockingQueue.take:()Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Message$Response
            astore 2 /* msg */
        start local 2 // org.apache.cassandra.transport.Message$Response msg
         3: .line 235
            aload 2 /* msg */
            instanceof org.apache.cassandra.transport.messages.ErrorMessage
            ifeq 5
         4: .line 236
            new java.lang.RuntimeException
            dup
            aload 2 /* msg */
            checkcast org.apache.cassandra.transport.messages.ErrorMessage
            getfield org.apache.cassandra.transport.messages.ErrorMessage.error:Lorg/apache/cassandra/exceptions/TransportException;
            checkcast java.lang.Throwable
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
         5: .line 237
      StackMap locals: org.apache.cassandra.transport.Message$Response
      StackMap stack:
            aload 2 /* msg */
         6: areturn
        end local 2 // org.apache.cassandra.transport.Message$Response msg
         7: .line 239
      StackMap locals: org.apache.cassandra.transport.SimpleClient org.apache.cassandra.transport.Message$Request
      StackMap stack: java.lang.InterruptedException
            astore 2 /* e */
        start local 2 // java.lang.InterruptedException e
         8: .line 241
            new java.lang.RuntimeException
            dup
            aload 2 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 2 // java.lang.InterruptedException e
        end local 1 // org.apache.cassandra.transport.Message$Request request
        end local 0 // org.apache.cassandra.transport.SimpleClient this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lorg/apache/cassandra/transport/SimpleClient;
            0    9     1  request  Lorg/apache/cassandra/transport/Message$Request;
            3    7     2      msg  Lorg/apache/cassandra/transport/Message$Response;
            8    9     2        e  Ljava/lang/InterruptedException;
      Exception table:
        from    to  target  type
           0     6       7  Class java.lang.InterruptedException
    MethodParameters:
         Name  Flags
      request  
}
SourceFile: "SimpleClient.java"
NestMembers:
  org.apache.cassandra.transport.SimpleClient$1  org.apache.cassandra.transport.SimpleClient$ConnectionTracker  org.apache.cassandra.transport.SimpleClient$EventHandler  org.apache.cassandra.transport.SimpleClient$Initializer  org.apache.cassandra.transport.SimpleClient$ResponseHandler  org.apache.cassandra.transport.SimpleClient$SecureInitializer  org.apache.cassandra.transport.SimpleClient$SimpleEventHandler
InnerClasses:
  public ClientEncryptionOptions = org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions of org.apache.cassandra.config.EncryptionOptions
  public abstract Factory = org.apache.cassandra.transport.Connection$Factory of org.apache.cassandra.transport.Connection
  public abstract Tracker = org.apache.cassandra.transport.Connection$Tracker of org.apache.cassandra.transport.Connection
  public Compressor = org.apache.cassandra.transport.Frame$Compressor of org.apache.cassandra.transport.Frame
  public Decompressor = org.apache.cassandra.transport.Frame$Decompressor of org.apache.cassandra.transport.Frame
  public Encoder = org.apache.cassandra.transport.Frame$Encoder of org.apache.cassandra.transport.Frame
  public SnappyCompressor = org.apache.cassandra.transport.FrameCompressor$SnappyCompressor of org.apache.cassandra.transport.FrameCompressor
  public ProtocolDecoder = org.apache.cassandra.transport.Message$ProtocolDecoder of org.apache.cassandra.transport.Message
  public ProtocolEncoder = org.apache.cassandra.transport.Message$ProtocolEncoder of org.apache.cassandra.transport.Message
  public abstract Request = org.apache.cassandra.transport.Message$Request of org.apache.cassandra.transport.Message
  public abstract Response = org.apache.cassandra.transport.Message$Response of org.apache.cassandra.transport.Message
  org.apache.cassandra.transport.SimpleClient$1
  private ConnectionTracker = org.apache.cassandra.transport.SimpleClient$ConnectionTracker of org.apache.cassandra.transport.SimpleClient
  public abstract EventHandler = org.apache.cassandra.transport.SimpleClient$EventHandler of org.apache.cassandra.transport.SimpleClient
  private Initializer = org.apache.cassandra.transport.SimpleClient$Initializer of org.apache.cassandra.transport.SimpleClient
  private ResponseHandler = org.apache.cassandra.transport.SimpleClient$ResponseHandler of org.apache.cassandra.transport.SimpleClient
  private SecureInitializer = org.apache.cassandra.transport.SimpleClient$SecureInitializer of org.apache.cassandra.transport.SimpleClient
  public SimpleEventHandler = org.apache.cassandra.transport.SimpleClient$SimpleEventHandler of org.apache.cassandra.transport.SimpleClient
  public Prepared = org.apache.cassandra.transport.messages.ResultMessage$Prepared of org.apache.cassandra.transport.messages.ResultMessage