Author: frm
Date: Thu Oct 26 14:17:01 2017
New Revision: 1813406
URL: http://svn.apache.org/viewvc?rev=1813406&view=rev
Log:
OAK-6829 - Let ForwardHandler react to channel active/inactive events
Modified:
jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
Modified:
jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java?rev=1813406&r1=1813405&r2=1813406&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
(original)
+++
jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/test/proxy/ForwardHandler.java
Thu Oct 26 14:17:01 2017
@@ -62,7 +62,7 @@ class ForwardHandler extends ChannelInbo
}
@Override
- public void channelRegistered(final ChannelHandlerContext ctx) throws
Exception {
+ public void channelActive(ChannelHandlerContext ctx) throws Exception {
group = new NioEventLoopGroup(0, r -> {
return new Thread(r, String.format("forward-handler-%d",
threadNumber.getAndIncrement()));
});
@@ -93,7 +93,7 @@ class ForwardHandler extends ChannelInbo
}
@Override
- public void channelUnregistered(ChannelHandlerContext ctx) throws
Exception {
+ public void channelInactive(ChannelHandlerContext ctx) throws Exception {
if (remote.close().awaitUninterruptibly(1, TimeUnit.SECONDS)) {
log.debug("Connection to remote host closed");
} else {
