(ChannelHandlerContext ctx, ChannelStateEvent e)
| 34 | } |
| 35 | |
| 36 | @Override |
| 37 | public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) |
| 38 | throws Exception { |
| 39 | byte[] md5 = digest.digest(); |
| 40 | BigInteger bigInt = new BigInteger(1, md5); |
| 41 | System.out.println("channelDisconnected tid=" + Thread.currentThread().getId() + " " + id |
| 42 | + " got " |
| 43 | + received + " " + bigInt.toString(16)); |
| 44 | latch.countDown(); |
| 45 | } |
| 46 | |
| 47 | @Override |
| 48 | public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception { |