ActiveMQ Aufbau von TCP-Socket mit mina
-
06-07-2019 - |
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?
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.