Слияние кода завершено, страница обновится автоматически
В исходном коде мастер-версии прямое использование Data из QuantumMessage вызвало отсутствие ответа из-за следующих изменений.
if (quantumMessage.getMessageType() == QuantumMessage.MessageType.DATA) {
proxyChannel.writeAndFlush(quantumMessage.getData().toByteArray());
} else {
log.info("Соединение уже открыто: {}:{}", quantumMessage.getTargetHost(), quantumMessage.getTargetPort());
}
В предыдущей версии было обнаружено, что использование Unpooled.copiedBuffer было успешным.
ByteBuf byteBuf = Unpooled.copiedBuffer(quantumMessage.getData().toByteArray());