final class org.xnio.ChannelListeners$TransferListener<I extends org.xnio.channels.StreamSourceChannel, O extends org.xnio.channels.StreamSinkChannel> implements org.xnio.ChannelListener<java.nio.channels.Channel>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: org.xnio.ChannelListeners$TransferListener
super_class: java.lang.Object
{
private final org.xnio.Pooled<java.nio.ByteBuffer> pooledBuffer;
descriptor: Lorg/xnio/Pooled;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/xnio/Pooled<Ljava/nio/ByteBuffer;>;
private final I source;
descriptor: Lorg/xnio/channels/StreamSourceChannel;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: TI;
private final O sink;
descriptor: Lorg/xnio/channels/StreamSinkChannel;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: TO;
private final org.xnio.ChannelListener<? super I> sourceListener;
descriptor: Lorg/xnio/ChannelListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/xnio/ChannelListener<-TI;>;
private final org.xnio.ChannelListener<? super O> sinkListener;
descriptor: Lorg/xnio/ChannelListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/xnio/ChannelListener<-TO;>;
private final org.xnio.ChannelExceptionHandler<? super O> writeExceptionHandler;
descriptor: Lorg/xnio/ChannelExceptionHandler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/xnio/ChannelExceptionHandler<-TO;>;
private final org.xnio.ChannelExceptionHandler<? super I> readExceptionHandler;
descriptor: Lorg/xnio/ChannelExceptionHandler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/xnio/ChannelExceptionHandler<-TI;>;
private long count;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private volatile int state;
descriptor: I
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
void <init>(long, org.xnio.Pooled<java.nio.ByteBuffer>, I, O, org.xnio.ChannelListener<? super I>, org.xnio.ChannelListener<? super O>, org.xnio.ChannelExceptionHandler<? super O>, org.xnio.ChannelExceptionHandler<? super I>, );
descriptor: (JLorg/xnio/Pooled;Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/channels/StreamSinkChannel;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelExceptionHandler;Lorg/xnio/ChannelExceptionHandler;I)V
flags: (0x0000)
Code:
stack=3, locals=11, args_size=10
start local 0 start local 1 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 start local 9 start local 10 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
lload 1
putfield org.xnio.ChannelListeners$TransferListener.count:J
2: aload 0
aload 3
putfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
3: aload 0
aload 4
putfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
4: aload 0
aload 5
putfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
5: aload 0
aload 6
putfield org.xnio.ChannelListeners$TransferListener.sourceListener:Lorg/xnio/ChannelListener;
6: aload 0
aload 7
putfield org.xnio.ChannelListeners$TransferListener.sinkListener:Lorg/xnio/ChannelListener;
7: aload 0
aload 8
putfield org.xnio.ChannelListeners$TransferListener.writeExceptionHandler:Lorg/xnio/ChannelExceptionHandler;
8: aload 0
aload 9
putfield org.xnio.ChannelListeners$TransferListener.readExceptionHandler:Lorg/xnio/ChannelExceptionHandler;
9: aload 0
iload 10
putfield org.xnio.ChannelListeners$TransferListener.state:I
10: return
end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/xnio/ChannelListeners$TransferListener<TI;TO;>;
0 11 1 count J
0 11 3 pooledBuffer Lorg/xnio/Pooled<Ljava/nio/ByteBuffer;>;
0 11 4 source TI;
0 11 5 sink TO;
0 11 6 sourceListener Lorg/xnio/ChannelListener<-TI;>;
0 11 7 sinkListener Lorg/xnio/ChannelListener<-TO;>;
0 11 8 writeExceptionHandler Lorg/xnio/ChannelExceptionHandler<-TO;>;
0 11 9 readExceptionHandler Lorg/xnio/ChannelExceptionHandler<-TI;>;
0 11 10 state I
Signature: (JLorg/xnio/Pooled<Ljava/nio/ByteBuffer;>;TI;TO;Lorg/xnio/ChannelListener<-TI;>;Lorg/xnio/ChannelListener<-TO;>;Lorg/xnio/ChannelExceptionHandler<-TO;>;Lorg/xnio/ChannelExceptionHandler<-TI;>;I)V
MethodParameters:
Name Flags
count final
pooledBuffer final
source final
sink final
sourceListener final
sinkListener final
writeExceptionHandler final
readExceptionHandler final
state final
public void handleEvent(java.nio.channels.Channel);
descriptor: (Ljava/nio/channels/Channel;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=10, args_size=2
start local 0 start local 1 0: aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.getResource:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 2
start local 2 1: aload 0
getfield org.xnio.ChannelListeners$TransferListener.state:I
istore 3
start local 3 2: aload 0
getfield org.xnio.ChannelListeners$TransferListener.count:J
lstore 4
start local 4 3: iload 3
tableswitch { // 0 - 1
0: 4
1: 38
default: 72
}
4: StackMap locals: java.nio.ByteBuffer int long
StackMap stack:
aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
lload 4
aload 2
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.transferTo:(JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
lstore 6
start local 6 5: goto 9
end local 6 StackMap locals:
StackMap stack: java.io.IOException
6: astore 9
start local 9 7: aload 0
aload 9
invokevirtual org.xnio.ChannelListeners$TransferListener.readFailed:(Ljava/io/IOException;)V
8: return
end local 9 start local 6 9: StackMap locals: long
StackMap stack:
lload 6
lconst_0
lcmp
ifne 12
aload 2
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 12
10: aload 0
lload 4
putfield org.xnio.ChannelListeners$TransferListener.count:J
11: return
12: StackMap locals:
StackMap stack:
lload 6
ldc -1
lcmp
ifne 18
13: lload 4
ldc 9223372036854775807
lcmp
ifne 16
14: aload 0
invokevirtual org.xnio.ChannelListeners$TransferListener.done:()V
15: return
16: StackMap locals:
StackMap stack:
aload 0
new java.io.EOFException
dup
invokespecial java.io.EOFException.<init>:()V
invokevirtual org.xnio.ChannelListeners$TransferListener.readFailed:(Ljava/io/IOException;)V
17: return
18: StackMap locals:
StackMap stack:
lload 4
ldc 9223372036854775807
lcmp
ifeq 34
19: lload 4
lload 6
lsub
lstore 4
20: goto 34
21: StackMap locals:
StackMap stack:
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
aload 2
invokeinterface org.xnio.channels.StreamSinkChannel.write:(Ljava/nio/ByteBuffer;)I
istore 8
start local 8 22: goto 26
end local 8 StackMap locals:
StackMap stack: java.io.IOException
23: astore 9
start local 9 24: aload 0
aload 9
invokevirtual org.xnio.ChannelListeners$TransferListener.writeFailed:(Ljava/io/IOException;)V
25: return
end local 9 start local 8 26: StackMap locals: int
StackMap stack:
lload 4
ldc 9223372036854775807
lcmp
ifeq 28
27: lload 4
iload 8
i2l
lsub
lstore 4
28: StackMap locals:
StackMap stack:
iload 8
ifne 34
29: aload 0
lload 4
putfield org.xnio.ChannelListeners$TransferListener.count:J
30: aload 0
iconst_1
putfield org.xnio.ChannelListeners$TransferListener.state:I
31: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.suspendReads:()V
32: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokeinterface org.xnio.channels.StreamSinkChannel.resumeWrites:()V
33: return
end local 8 34: StackMap locals:
StackMap stack:
aload 2
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 21
35: lload 4
lconst_0
lcmp
ifne 4
36: aload 0
invokevirtual org.xnio.ChannelListeners$TransferListener.done:()V
37: return
end local 6 38: StackMap locals:
StackMap stack:
goto 48
39: StackMap locals:
StackMap stack:
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
aload 2
invokeinterface org.xnio.channels.StreamSinkChannel.write:(Ljava/nio/ByteBuffer;)I
istore 8
start local 8 40: goto 44
end local 8 StackMap locals:
StackMap stack: java.io.IOException
41: astore 9
start local 9 42: aload 0
aload 9
invokevirtual org.xnio.ChannelListeners$TransferListener.writeFailed:(Ljava/io/IOException;)V
43: return
end local 9 start local 8 44: StackMap locals: org.xnio.ChannelListeners$TransferListener java.nio.channels.Channel java.nio.ByteBuffer int long top top int
StackMap stack:
lload 4
ldc 9223372036854775807
lcmp
ifeq 46
45: lload 4
iload 8
i2l
lsub
lstore 4
46: StackMap locals:
StackMap stack:
iload 8
ifne 48
47: return
end local 8 48: StackMap locals: org.xnio.ChannelListeners$TransferListener java.nio.channels.Channel java.nio.ByteBuffer int long
StackMap stack:
aload 2
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 39
49: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
lload 4
aload 2
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.transferTo:(JLjava/nio/ByteBuffer;Lorg/xnio/channels/StreamSinkChannel;)J
lstore 6
start local 6 50: goto 54
end local 6 StackMap locals:
StackMap stack: java.io.IOException
51: astore 9
start local 9 52: aload 0
aload 9
invokevirtual org.xnio.ChannelListeners$TransferListener.readFailed:(Ljava/io/IOException;)V
53: return
end local 9 start local 6 54: StackMap locals: long
StackMap stack:
lload 6
lconst_0
lcmp
ifne 60
aload 2
invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
ifne 60
55: aload 0
lload 4
putfield org.xnio.ChannelListeners$TransferListener.count:J
56: aload 0
iconst_0
putfield org.xnio.ChannelListeners$TransferListener.state:I
57: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokeinterface org.xnio.channels.StreamSinkChannel.suspendWrites:()V
58: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.resumeReads:()V
59: return
60: StackMap locals:
StackMap stack:
lload 6
ldc -1
lcmp
ifne 66
61: lload 4
ldc 9223372036854775807
lcmp
ifne 64
62: aload 0
invokevirtual org.xnio.ChannelListeners$TransferListener.done:()V
63: return
64: StackMap locals:
StackMap stack:
aload 0
new java.io.EOFException
dup
invokespecial java.io.EOFException.<init>:()V
invokevirtual org.xnio.ChannelListeners$TransferListener.readFailed:(Ljava/io/IOException;)V
65: return
66: StackMap locals:
StackMap stack:
lload 4
ldc 9223372036854775807
lcmp
ifeq 68
67: lload 4
lload 6
lsub
lstore 4
68: StackMap locals:
StackMap stack:
lload 4
lconst_0
lcmp
ifne 71
69: aload 0
invokevirtual org.xnio.ChannelListeners$TransferListener.done:()V
70: return
end local 6 71: StackMap locals:
StackMap stack:
goto 48
72: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 73 0 this Lorg/xnio/ChannelListeners$TransferListener<TI;TO;>;
0 73 1 channel Ljava/nio/channels/Channel;
1 73 2 buffer Ljava/nio/ByteBuffer;
2 73 3 state I
3 73 4 count J
5 6 6 lres J
9 38 6 lres J
50 51 6 lres J
54 71 6 lres J
22 23 8 ires I
26 34 8 ires I
40 41 8 ires I
44 48 8 ires I
7 9 9 e Ljava/io/IOException;
24 26 9 e Ljava/io/IOException;
42 44 9 e Ljava/io/IOException;
52 54 9 e Ljava/io/IOException;
Exception table:
from to target type
4 5 6 Class java.io.IOException
21 22 23 Class java.io.IOException
39 40 41 Class java.io.IOException
49 50 51 Class java.io.IOException
MethodParameters:
Name Flags
channel final
private void writeFailed(java.io.IOException);
descriptor: (Ljava/io/IOException;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.suspendReads:()V
1: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokeinterface org.xnio.channels.StreamSinkChannel.suspendWrites:()V
2: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
aload 0
getfield org.xnio.ChannelListeners$TransferListener.writeExceptionHandler:Lorg/xnio/ChannelExceptionHandler;
aload 1
invokestatic org.xnio.ChannelListeners.invokeChannelExceptionHandler:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelExceptionHandler;Ljava/io/IOException;)V
3: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 2
5: aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.free:()V
6: aload 2
athrow
7: StackMap locals:
StackMap stack:
aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.free:()V
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/xnio/ChannelListeners$TransferListener<TI;TO;>;
0 9 1 e Ljava/io/IOException;
Exception table:
from to target type
0 4 4 any
MethodParameters:
Name Flags
e final
private void readFailed(java.io.IOException);
descriptor: (Ljava/io/IOException;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
invokeinterface org.xnio.channels.StreamSourceChannel.suspendReads:()V
1: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokeinterface org.xnio.channels.StreamSinkChannel.suspendWrites:()V
2: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
aload 0
getfield org.xnio.ChannelListeners$TransferListener.readExceptionHandler:Lorg/xnio/ChannelExceptionHandler;
aload 1
invokestatic org.xnio.ChannelListeners.invokeChannelExceptionHandler:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelExceptionHandler;Ljava/io/IOException;)V
3: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
4: astore 2
5: aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.free:()V
6: aload 2
athrow
7: StackMap locals:
StackMap stack:
aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.free:()V
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/xnio/ChannelListeners$TransferListener<TI;TO;>;
0 9 1 e Ljava/io/IOException;
Exception table:
from to target type
0 4 4 any
MethodParameters:
Name Flags
e final
private void done();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=1
start local 0 0: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sourceListener:Lorg/xnio/ChannelListener;
astore 1
start local 1 1: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sinkListener:Lorg/xnio/ChannelListener;
astore 2
start local 2 2: aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
astore 3
start local 3 3: aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
astore 4
start local 4 4: aload 3
aload 1
invokestatic org.xnio.channels.Channels.setReadListener:(Lorg/xnio/channels/SuspendableReadChannel;Lorg/xnio/ChannelListener;)V
5: aload 1
ifnonnull 8
6: aload 3
invokeinterface org.xnio.channels.StreamSourceChannel.suspendReads:()V
7: goto 9
8: StackMap locals: org.xnio.ChannelListeners$TransferListener org.xnio.ChannelListener org.xnio.ChannelListener org.xnio.channels.StreamSourceChannel org.xnio.channels.StreamSinkChannel
StackMap stack:
aload 3
invokeinterface org.xnio.channels.StreamSourceChannel.wakeupReads:()V
9: StackMap locals:
StackMap stack:
aload 4
aload 2
invokestatic org.xnio.channels.Channels.setWriteListener:(Lorg/xnio/channels/SuspendableWriteChannel;Lorg/xnio/ChannelListener;)V
10: aload 2
ifnonnull 13
11: aload 4
invokeinterface org.xnio.channels.StreamSinkChannel.suspendWrites:()V
12: goto 18
13: StackMap locals:
StackMap stack:
aload 4
invokeinterface org.xnio.channels.StreamSinkChannel.wakeupWrites:()V
end local 4 end local 3 end local 2 end local 1 14: goto 18
StackMap locals: org.xnio.ChannelListeners$TransferListener
StackMap stack: java.lang.Throwable
15: astore 5
16: aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.free:()V
17: aload 5
athrow
18: StackMap locals:
StackMap stack:
aload 0
getfield org.xnio.ChannelListeners$TransferListener.pooledBuffer:Lorg/xnio/Pooled;
invokeinterface org.xnio.Pooled.free:()V
19: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/xnio/ChannelListeners$TransferListener<TI;TO;>;
1 14 1 sourceListener Lorg/xnio/ChannelListener<-TI;>;
2 14 2 sinkListener Lorg/xnio/ChannelListener<-TO;>;
3 14 3 source TI;
4 14 4 sink TO;
Exception table:
from to target type
0 15 15 any
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "Transfer channel listener ("
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.xnio.ChannelListeners$TransferListener.source:Lorg/xnio/channels/StreamSourceChannel;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " to "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sink:Lorg/xnio/channels/StreamSinkChannel;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc ") -> ("
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sourceListener:Lorg/xnio/ChannelListener;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " and "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.xnio.ChannelListeners$TransferListener.sinkListener:Lorg/xnio/ChannelListener;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc ")"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/ChannelListeners$TransferListener<TI;TO;>;
}
Signature: <I::Lorg/xnio/channels/StreamSourceChannel;O::Lorg/xnio/channels/StreamSinkChannel;>Ljava/lang/Object;Lorg/xnio/ChannelListener<Ljava/nio/channels/Channel;>;
SourceFile: "ChannelListeners.java"
NestHost: org.xnio.ChannelListeners
InnerClasses:
final TransferListener = org.xnio.ChannelListeners$TransferListener of org.xnio.ChannelListeners