Question

J'essaie de mettre en place une simple démo d'activemq et de mina. J'ai modifié le fichier camelContext dans le fichier activemq.xml afin d'inclure deux sockets mina tcp, deux files d'attente et des routes en tant que telles:

auditeurA - > qA - > auditeurB
auditeurB - > qB - > auditeurA

L'intention est de faire passer un message dans les deux sens 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> 

Lorsque je lance activemq, une exception se produit:

org.apache.camel.NoSuchEndpointException: aucun noeud final n'a été trouvé pour: mina: tcp: // localhost: 42000? textline = true

Dois-je explicitement ajouter un haricot mina? Si oui où et comment?

Était-ce utile?

La solution

Avez-vous camel-mina.jar et les jarres mina sur le chemin de classe?

Basé sur le fil ici , il semble avoir réglé le problème.

Licencié sous: CC-BY-SA avec attribution
Non affilié à StackOverflow
scroll top