public class org.postgresql.replication.PGReplicationConnectionImpl implements org.postgresql.replication.PGReplicationConnection
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.postgresql.replication.PGReplicationConnectionImpl
  super_class: java.lang.Object
{
  private org.postgresql.core.BaseConnection connection;
    descriptor: Lorg/postgresql/core/BaseConnection;
    flags: (0x0002) ACC_PRIVATE

  public void <init>(org.postgresql.core.BaseConnection);
    descriptor: (Lorg/postgresql/core/BaseConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
        start local 1 // org.postgresql.core.BaseConnection connection
         0: .line 20
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 21
            aload 0 /* this */
            aload 1 /* connection */
            putfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
         2: .line 22
            return
        end local 1 // org.postgresql.core.BaseConnection connection
        end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lorg/postgresql/replication/PGReplicationConnectionImpl;
            0    3     1  connection  Lorg/postgresql/core/BaseConnection;
    MethodParameters:
            Name  Flags
      connection  

  public org.postgresql.replication.fluent.ChainedStreamBuilder replicationStream();
    descriptor: ()Lorg/postgresql/replication/fluent/ChainedStreamBuilder;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
         0: .line 26
            new org.postgresql.replication.fluent.ReplicationStreamBuilder
            dup
            aload 0 /* this */
            getfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
            invokespecial org.postgresql.replication.fluent.ReplicationStreamBuilder.<init>:(Lorg/postgresql/core/BaseConnection;)V
            areturn
        end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/postgresql/replication/PGReplicationConnectionImpl;

  public org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder createReplicationSlot();
    descriptor: ()Lorg/postgresql/replication/fluent/ChainedCreateReplicationSlotBuilder;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
         0: .line 31
            new org.postgresql.replication.fluent.ReplicationCreateSlotBuilder
            dup
            aload 0 /* this */
            getfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
            invokespecial org.postgresql.replication.fluent.ReplicationCreateSlotBuilder.<init>:(Lorg/postgresql/core/BaseConnection;)V
            areturn
        end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/postgresql/replication/PGReplicationConnectionImpl;

  public void dropReplicationSlot(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
        start local 1 // java.lang.String slotName
         0: .line 36
            aload 1 /* slotName */
            ifnull 1
            aload 1 /* slotName */
            invokevirtual java.lang.String.isEmpty:()Z
            ifeq 2
         1: .line 37
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
            ldc "Replication slot name can't be null or empty"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 40
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.postgresql.replication.PGReplicationConnectionImpl.connection:Lorg/postgresql/core/BaseConnection;
            invokeinterface org.postgresql.core.BaseConnection.createStatement:()Ljava/sql/Statement;
            astore 2 /* statement */
        start local 2 // java.sql.Statement statement
         3: .line 42
            aload 2 /* statement */
            new java.lang.StringBuilder
            dup
            ldc "DROP_REPLICATION_SLOT "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* slotName */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface java.sql.Statement.execute:(Ljava/lang/String;)Z
            pop
         4: .line 43
            goto 8
      StackMap locals: org.postgresql.replication.PGReplicationConnectionImpl java.lang.String java.sql.Statement
      StackMap stack: java.lang.Throwable
         5: astore 3
         6: .line 44
            aload 2 /* statement */
            invokeinterface java.sql.Statement.close:()V
         7: .line 45
            aload 3
            athrow
         8: .line 44
      StackMap locals:
      StackMap stack:
            aload 2 /* statement */
            invokeinterface java.sql.Statement.close:()V
         9: .line 46
            return
        end local 2 // java.sql.Statement statement
        end local 1 // java.lang.String slotName
        end local 0 // org.postgresql.replication.PGReplicationConnectionImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   10     0       this  Lorg/postgresql/replication/PGReplicationConnectionImpl;
            0   10     1   slotName  Ljava/lang/String;
            3   10     2  statement  Ljava/sql/Statement;
      Exception table:
        from    to  target  type
           3     5       5  any
    Exceptions:
      throws java.sql.SQLException
    MethodParameters:
          Name  Flags
      slotName  
}
SourceFile: "PGReplicationConnectionImpl.java"