Akka Camel：endpoint上没有可用的消费者

Question

我是Akka的新手，正在尝试使用camel组件。

我在这里简化了代码，但基本上我有一个使用者参与者，它从JMSendpoint使用。

因此，我尝试这种“直接”方法，但在endpoint:endpoint[direct://mycamelendpoint]上没有可用的消费者。Exchange[message:My test message]异常。

我在这里缺少什么配置？

object TestApp extends App {
  implicit val system = ActorSystem()
  val camel = CamelExtension(system)
  val producer = system.actorOf(Props[MyProducer])
  val consumer = system.actorOf(Props[MyConsumer])

  producer ! "My test message"


}

class MyProducer extends Producer {
  override def endpointUri: String = "direct:myCamelEndpoint"
}

class MyConsumer extends Consumer with ActorLogging{
  override def endpointUri: String = "direct:myCamelEndpoint"

  override def receive: Receive = {
    case event: Any => log.info("Received event {}", event)
  }
}

Answer 1

使用seda而不是direct，因为seda的行为更像JMS。