File tree 1 file changed +4
-4
lines changed
src/main/java/io/r2dbc/postgresql/client
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -40,17 +40,17 @@ final class SSLSessionHandlerAdapter extends AbstractPostgresSSLHandlerAdapter {
40
40
}
41
41
42
42
@ Override
43
- public void channelActive (ChannelHandlerContext ctx ) {
43
+ public void channelActive (ChannelHandlerContext ctx ) throws Exception {
44
44
Mono .from (SSLRequest .INSTANCE .encode (this .alloc )).subscribe (ctx ::writeAndFlush );
45
- ctx . fireChannelActive ( );
45
+ super . channelActive ( ctx );
46
46
}
47
47
48
48
@ Override
49
- public void channelInactive (ChannelHandlerContext ctx ) {
49
+ public void channelInactive (ChannelHandlerContext ctx ) throws Exception {
50
50
// If we receive channel inactive before removing this handler, then the inbound has closed early.
51
51
PostgresqlSslException e = new PostgresqlSslException ("Connection closed during SSL negotiation" );
52
52
completeHandshakeExceptionally (e );
53
- ctx . fireChannelInactive ( );
53
+ super . channelInactive ( ctx );
54
54
}
55
55
56
56
@ Override
You can’t perform that action at this time.
0 commit comments