| 1159 | } |
| 1160 | |
| 1161 | @Override |
| 1162 | public void channelClosed(final ChannelHandlerContext ctx, |
| 1163 | final ChannelStateEvent e) { |
| 1164 | chan = null; |
| 1165 | // No need to call super.channelClosed() because we already called |
| 1166 | // super.channelDisconnected(). If we get here without getting a |
| 1167 | // DISCONNECTED event, then we were never connected in the first place so |
| 1168 | // the ReplayingDecoder has nothing to cleanup. |
| 1169 | cleanup(e.getChannel()); |
| 1170 | } |
| 1171 | |
| 1172 | /** |
| 1173 | * Cleans up any outstanding or lingering RPC (used when shutting down). |