Configurazione ActiveMQ del socket tcp usando mina
-
06-07-2019 - |
Domanda
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?
Soluzione
Hai cammelli-mina.jar e i barattoli di mina sul sentiero di classe?
Basato su il thread qui sembra averlo corretto.