package com.example.mina.server.box.rmasm;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolEncoder;
import org.apache.mina.filter.codec.ProtocolEncoderOutput;
public class RmasmMessageEncoder implements ProtocolEncoder {
@Override
public void encode(IoSession session, Object message, ProtocolEncoderOutput out) {
if (message instanceof RmasmResponseMessage) {
byte[] result = ((RmasmResponseMessage) message).getResult();
//session.write(IoBuffer.wrap(result));
IoBuffer w = IoBuffer.wrap(result);
session.write(w);
}
}
@Override
public void dispose(IoSession session) {
}
}