ClientSessionHandler

package cnc;

import java.util.Map;
import java.util.Optional;
import java.util.concurrent.ConcurrentHashMap;

import org.apache.mina.core.service.IoHandler;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.FilterEvent;

public class ClientSessionHandler implements IoHandler {

    private IoSession cncSession;
    private Map<String, Optional<StringBuffer>> sessionBuffers = new ConcurrentHashMap<>();

    @Override
    public void sessionCreated(IoSession session) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void sessionOpened(IoSession session) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void sessionClosed(IoSession session) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void messageReceived(IoSession session, Object message) throws Exception {

        String sessionID = session.getId()+"";
        System.out.print("Client has got: "+ message + " " + sessionID);
        if(null == sessionBuffers.get(sessionID) || Optional.empty().equals(sessionID)) {
            sessionBuffers.put(sessionID, Optional.of(new StringBuffer()));
        }
        sessionBuffers.get(sessionID).get().append((String)message);

    }

    @Override
    public void messageSent(IoSession session, Object message) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void inputClosed(IoSession session) throws Exception {
        // TODO Auto-generated method stub

    }

    @Override
    public void event(IoSession session, FilterEvent event) throws Exception {
        // TODO Auto-generated method stub

    }

    public void setServerWritingSession(IoSession cncSession) {
        this.cncSession = cncSession;
    }



}