this.streamAlgorithm = streamAlgorithm; this.messageProcessor = IncomeMessageProcessor.getMessageProcessorForPort(streamAlgorithm.getPort());
if (code == REQUEST_BUFFERED) { final ByteBuffer messageBuffer = streamAlgorithm.getByteBuffer(); final SocketChannel socketChannel = streamAlgorithm.getSocketChannel(); messageProcessor.process(messageBuffer, socketChannel); } return BREAK;