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?

Foi útil?

Solução

Você tem de camelo mina.jar e os frascos mina no classpath?

Com base o fio aqui parece ter fixa-lo.

Licenciado em: CC-BY-SA com atribuição
Não afiliado a StackOverflow
scroll top