package com.ld.io.netty.server;
|
|
import com.ld.io.api.InvokeResult;
|
import com.ld.io.api.IoMsgConsumer;
|
import com.ld.io.api.IoSession;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
public class DefaultMessageConsume implements IoMsgConsumer {
|
private final Logger logger = LoggerFactory.getLogger(getClass());
|
|
@Override
|
public void consume(IoSession session, byte[] bytes) {
|
logger.info("consume message=" + new String(bytes));
|
session.setBusinessKey("BUSINESS_KEY");
|
InvokeResult invoke = session.invoke("CCDDEEFFAA".getBytes());
|
logger.info("invoke result=" + invoke);
|
}
|
|
}
|
