kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

同上追加

This commit is contained in:
zhangxin10 2015-11-13 22:26:30 +08:00
parent 330c6b377d
commit f8ccbef2b1
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
View File

@ -1,12 +1,13 @@
package com.ai.cloud.skywalking.reciever.handler;
import com.ai.cloud.skywalking.reciever.buffer.DataBufferThreadContainer;
import com.ai.cloud.skywalking.reciever.util.ByteArrayUtil;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
public class CollectionServerDataHandler extends SimpleChannelInboundHandler {
public class CollectionServerDataHandler extends SimpleChannelInboundHandler<byte[]> {
@Override
protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
DataBufferThreadContainer.getDataBufferThread().doCarry(msg.toString().getBytes());
protected void channelRead0(ChannelHandlerContext ctx, byte[] msg) throws Exception {
DataBufferThreadContainer.getDataBufferThread().doCarry(msg);
}
}