Frage

Ich versuche, eine einfache Demo von activemq und mina einzurichten. Ich habe das camelContext in der activemq.xml Datei zwei mina TCP-Sockets zu schließen, zwei Warteschlangen und Routen wie zum Beispiel:

listenerA -> qA -> listenerB
listenerB -> QB -> listenerA

Die Absicht ist es zwei Wege durchlaufen zwischen zwei Telnet-Sitzungen zu haben. Später werde ich mehr Phantasie Funktionen wie Filterung hinzufügen, das Routing zu einem Thema und meine eigenen Codec auf jedem Zuhörer.

Hier ist meine camelcontext:      

    <!-- You can use a <package> element for each root package to search for Java routes --> 
    <package>com.myco.codec</package> 

    <endpoint id="listener_A" uri="mina:tcp://localhost:42000?textline=true"/> 
    <endpoint id="listener_B" uri="mina:tcp://localhost:42001?textline=true"/> 

            <!-- You can use Spring XML syntax to define the routes here using the <route> element --> 
    <route> 
        <from ref="listener_A"/> 
        <to uri="activemq:qA"/> 
    </route> 
    <route> 
        <from uri="activemq:qB"/> 
        <to ref="listener_A"/> 
    </route> 
    <route> 
        <from ref="listener_B"/> 
        <to uri="activemq:qB"/> 
    </route> 
    <route> 
        <from uri="activemq:qA"/> 
        <to ref="listener_B"/> 
    </route> 
</camelContext> 

Wenn ich activemq starten erhalte ich eine Ausnahme:

org.apache.camel.NoSuchEndpointException: mina: Es konnte kein Endpunkt gefunden werden tcp: // localhost: 42000 Textzeile = true

Muss ich explizit eine mina Bohne hinzufügen? Wenn ja, wo und wie?

War es hilfreich?

Lösung

Haben Sie Kamel mina.jar und die mina Gläser auf dem Classpath?

Basierend auf den Faden hier es scheint, es behoben zu haben.

Lizenziert unter: CC-BY-SA mit Zuschreibung
Nicht verbunden mit StackOverflow
scroll top