が含まれている私は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、クラスパスに必要なものが含まれていることを確認してください キャメルコンポーネントジャー。
ませ運を、まだ同じ問題が解消されません。 – Jet
プロジェクトに必要な 'camel-spring'依存関係はありますか? – hveiga
はい私は 'camel-spring'依存性を追加しました。 – Jet