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);
    }

}