2017-01-13 1 views
0

У меня есть верблюжий маршрут в граале. Исключение уходит, когда я прокомментирую строку unmarshall в процессоре, как если бы слишком много времени, чтобы ответ TCP был отправлен обратно во времени. Если моя оценка правильная, если есть параметр в netty для отправки ответа без ожидания?CamelExchangeException: Невозможно написать ответ ... вызванный UnsupportedException

Спасибо.

from("netty4:tcp://172.25.200.66:12345? 
clientMode=true&disconnectOnNoReply=false&connectTimeout=100000 
&reconnect=true&allowDefaultCodec=false&decoder=#jsonDecoderFactory") 
.to("log:dump?showAll=true") 
.bean("messageProcessorService", "processMessage") 


def processMessage (String msg) { 
    log.debug("MessageProcessorService processMessage") 
    def object = unmarshall(msg) 
} 


2017-01-13 13:20:58,186 | WARN | camel.component.netty4.NettyConsumer | 
    Caused by: [org.apache.camel.CamelExchangeException - Cannot write response to /172.25.200.66:12345. 
    Exchange[ID-wulg2-chij-udev-local-41278-1484313632001-0-20][Message: []]. 
    Caused by: [java.lang.UnsupportedOperationException - unsupported message 
    type: Collections$UnmodifiableList (expected: ByteBuf, FileRegion)]] 
    org.apache.camel.CamelExchangeException: Cannot write response to 
    /172.25.200.66:12345. 
    Exchange[ID-wulg2-chij-udev-local-41278-1484313632001-0-20][Message: []]. 
    Caused by: [java.lang.UnsupportedOperationException - unsupported message 

ответ

0

Оказывается, опция «sync = false» устанавливает конечную точку в одну сторону. Таким образом, не требуется писать ответы назад.

Смежные вопросы