Configurazione ActiveMQ del socket tcp usando mina

Question

Sto cercando di impostare una semplice demo di activemq e mina. Ho modificato camelContext nel file activemq.xml per includere due socket mina tcp, due code e route come tali:

listenerA - > qA - > listenerB
listenerB - > qB - > listenerA

L'intenzione è quella di far passare due vie tra due sessioni telnet. Più tardi, aggiungerò altre funzioni fantasiose come il filtro, il routing a un argomento e il mio codec su ciascun ascoltatore.

Ecco il mio 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> 

Quando avvio activemq ricevo un'eccezione:

org.apache.camel.NoSuchEndpointException: Impossibile trovare un endpoint per: mina: tcp: // localhost: 42000? textline = true

Devo esplicitamente aggiungere un mina bean? Se sì, dove e come?

Answer 1

Hai cammelli-mina.jar e i barattoli di mina sul sentiero di classe?

Basato su il thread qui sembra averlo corretto.