camel-akka 및 응답자의 답변

Question

친애하는 Akka/Camel 마스터!

(netty4 : TCP) -> 내가 경로 다음 한

(akka : 배우)

내가 akka - 낙타 모듈 어디에 사용하고 있습니다 :

akka : 배우 타입 UntypedConsumerActor이다 나는 TCP 소켓에 바이트를 보낼 때 나는 어떤 전화 예외가 발생 배우

netty4:tcp://localhost:8000?textline=true 

: netty4 : TCP는 akka의 getEndopointUri 방법에 정의 된 엔드 포인트입니다 해당 소켓 채널이 닫혀 있습니까?

Caused by: java.nio.channels.ClosedChannelException: null 
     at io.netty.channel.AbstractChannel$AbstractUnsafe.write(...)(Unknown Source) [netty-all-4.1.4.Final.jar:4.1.4.Final] 

Message History 
--------------------------------------------------------------------------------------------------------------------------------------- 
RouteId    ProcessorId   Processor                  Elapsed (ms) 
[akka://FileDaemonS] [akka://FileDaemonS] [tcp://localhost:8000               ] [  60061] 
[akka://FileDaemonS] [to1    ] [akka://FileDaemonSystem/user/FileDaemonTcpEndpoint?autoAck=false&replyTimeout=] [  60037] 
java.util.concurrent.TimeoutException: Failed to get response from the actor [ActorEndpointPath(akka://FileDaemonSystem/user/FileDaemonTcpEndpoint)] within timeout [1 minute]. Check replyTimeout and blocking settings [Endpoint[akka://FileDaemonSystem/user/FileDaemonTcpEndpoint?autoAck=false&replyTimeout=60000+milliseconds]] 
     at akka.camel.internal.component.ActorProducer$$anonfun$1.applyOrElse(ActorComponent.scala:151) ~[akka-camel_2.11-2.4.9.jar:na] 
     at akka.camel.internal.component.ActorProducer$$anonfun$1.applyOrElse(ActorComponent.scala:148) ~[akka-camel_2.11-2.4.9.jar:na] 
     at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) ~[scala-library-2.11.8.jar:na] 
     at scala.PartialFunction$AndThen.apply(PartialFunction.scala:186) [scala-library-2.11.8.jar:na] 
     at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) [scala-library-2.11.8.jar:na] 

무엇이 잘못 되었나요?

Answer 1

해결책을 찾았습니다. 단방향으로 끝점을 설정하면 문제가 해결됩니다.

netty4:tcp://localhost:8000?textline=true&sync=false