2017-12-07 11 views
4

が含まれている私は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、クラスパスに必要なものが含まれていることを確認してください キャメルコンポーネントジャー。

答えて

0

私はあなたがテストモックエンドポイントに名前を提供する必要があると信じています。testが機能しない可能性があります。 test:myMockEndpointをやってみることはできますか?

あなたがここで見てみることはできません。http://camel.apache.org/components.html

+0

ませ運を、まだ同じ問題が解消されません。 – Jet

+0

プロジェクトに必要な 'camel-spring'依存関係はありますか? – hveiga

+0

はい私は 'camel-spring'依存性を追加しました。 – Jet

関連する問題