|
@@ -44,7 +44,6 @@ public class ChargeServer {
|
|
@Override
|
|
@Override
|
|
protected void initChannel(SocketChannel socketChannel) throws Exception {
|
|
protected void initChannel(SocketChannel socketChannel) throws Exception {
|
|
socketChannel.pipeline()
|
|
socketChannel.pipeline()
|
|
- .addLast(new LineBasedFrameDecoder(1024))
|
|
|
|
.addLast(new ChargeMessageDecoder())
|
|
.addLast(new ChargeMessageDecoder())
|
|
.addLast(new ChargeMessageEncoder())
|
|
.addLast(new ChargeMessageEncoder())
|
|
.addLast(new ChargeMessageHandler());
|
|
.addLast(new ChargeMessageHandler());
|