ActiveMQ configuração do soquete tcp usando mina
-
06-07-2019 - |
Pergunta
Eu estou tentando configurar um simples demonstração de activemq e mina. Eu editei a camelContext no arquivo activemq.xml para incluir dois soquetes mina tcp, duas filas e rotas como tal:
listenerA -> qA -> listenerB
listenerB -> QB -> listenerA
A intenção é ter duas passagens através entre duas sessões de telnet. Mais tarde, vou acrescentar mais chique características tais como filtragem, encaminhamento para um tópico e minha própria codec em cada ouvinte.
Aqui está o meu 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 eu começar activemq eu recebo uma exceção:
org.apache.camel.NoSuchEndpointException: No ponto final poderia ser encontrado para: mina: tcp: // localhost: 42000 TextLine = true
Do I explicitamente precisa adicionar um feijão mina? Se assim for, onde e como?
Solução
Você tem de camelo mina.jar e os frascos mina no classpath?
Com base o fio aqui parece ter fixa-lo.