Не удалось найти конечную точку для: test, пожалуйста, проверьте, что ваш classpath содержит необходимый jar компонента Camel

Question

Я пытаюсь отправлять и получать сообщения, используя akka-camel и создал пример для производителя и потребителя, как показано ниже:

Режиссер:

import akka.actor.{Actor, ActorSystem, Props}
import akka.camel.Producer

class CamelJmsProducer extends Actor with Producer {
  override def endpointUri = "test"
}

object CamelJmsProducerApp extends App {
  val system = ActorSystem("some-system")
  val ref = system.actorOf(Props[CamelJmsProducer])
  ref ! "HEY"
}

Потребитель:

import akka.actor.{Actor, ActorSystem, Props}
import akka.camel.{CamelMessage, Consumer}

class CamelJmsConsumer extends Actor with Consumer {
  override def receive = {
    case msg: CamelMessage ⇒ println("RECEIVED >>> " + msg)
    case _ ⇒ println("RECEIVED NOTHING>>> ")
  }

  override def endpointUri = "test"
}

object CamelJmsConsumerApp extends App {
  val system = ActorSystem("some-system1")
  system.actorOf(Props[CamelJmsConsumer])
}

Но я сталкиваюсь с проблемой как производителя, так и потребителя, как показано ниже. Чего мне не хватает?

Режиссер:

java.lang.IllegalArgumentException: место назначения должно быть указано

Потребитель:

Вызвано: org.apache.camel.NoSuchEndpointException: Конечная точка не может быть найдена для: test, пожалуйста, проверьте, что ваш путь к классам содержит необходимый jar компонента Camel.

Answer 1

Я считаю, что вам нужно предоставить имя конечной точке тестового макета, просто test может не сработать. Можете ли вы попробовать делать test:myMockEndpoint?

Вы можете посмотреть здесь: http://camel.apache.org/components.html