Configuration d'ActiveMQ de socket tcp en utilisant mina

Question

J'essaye de configurer une démo simple d'activemq et de mina. J'ai modifié le camelContext dans le fichier activemq.xml pour inclure deux prises mina tcp, deux files d'attente et des itinéraires en tant que tels:

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

Le but est d'avoir un double chemin entre deux sessions Telnet. Plus tard, j'ajouterai des fonctionnalités plus sophistiquées telles que le filtrage, le routage vers un sujet et mon propre codec sur chaque écouteur.

Voici mon 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> 

Quand je commence ActiveMQ je reçois une exception:

org.apache.camel.NoSuchEndpointException: Aucun critère n'a pu être trouvée pour: mina: tcp:// localhost: 42000? textline = true

Ai-je explicitement besoin d'ajouter un haricot mina? Si c'est le cas, où et comment?

Answer 1

Avez-vous camel-mina.jar et les mina jars sur le classpath? Basé sur the thread here, il semble l'avoir corrigé.