Camel Netty Tcp двунаправленный - PullRequest
Новая
       9

Camel Netty Tcp двунаправленный

0 голосов
/ 24 августа 2018

Это было немного сложно в течение всей недели, я все еще борюсь с проблемой с Camel-Netty.

Источник контекста TCP (определение службы) устанавливается со следующим netty4: tcp :, sync = true, синхронный = true, clientMode = false, TransferExchange = true, allowDefaultCodec = false, keepAlive = true, tcpNoDelay =true, decoders = # Decoders

Объект Tcp Context установлен с 

context.setTracing(true)
context.setStreamCaching(true)

Конфигурация маршрутов установлена ​​с 

from(sourceInfo)
.process(<processor code>)
.filter(body().isNotNull())
.filter(body().isNotEqualTo(""))
.log("Message Body = [${body}]")
.multicast()
.parallelProcessing()
.inOnly("direct:forwardmessage")
.to("mock:closemessage")
.transform().constant("ACK");

//forward the Message body to Kafka.
from("direct:forwardmessage")
.to(targetInfo) ;

Я ожидаю, что этот параметр должен вернутьответное сообщение («ACK») клиенту TCP, отправляющему сообщение в порт.

Но этого не происходит, поскольку клиенты не получают строку «ACK» в качестве ответа от службы.

Действительно ли это возможно с Camel Netty TCP или я должен перейти к реализации стандартного сокета NIO?

Уверен, я не первый с этой проблемой, поэтому запрашиваю помощь / предложения по ее решению.выпуск.

...