Настройка ActiveMQ TCP-сокета с использованием mina

Я пытаюсь установить простую демонстрацию activemq и mina. Я отредактировал camelContext в файле activemq.xml, включив в него два сокета mina tcp, две очереди и маршруты как таковые:

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

Намерение состоит в том, чтобы иметь двусторонний проход между двумя сеансами telnet. Позже я добавлю больше необычных функций, таких как фильтрация, маршрутизация по теме и мой собственный кодек для каждого слушателя.

Вот мой верблюжий контекст:

    <!-- 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> 

Когда я запускаю activemq, я получаю исключение:

org.apache.camel.NoSuchEndpointException: не удалось найти конечную точку для: mina: tcp: // localhost: 42000? textline = true

Мне явно нужно добавить бин мина? Если да, то где и как?


person JeffV    schedule 05.11.2008    source источник


Ответы (1)


У вас есть camel-mina.jar и jar-файлы mina в пути к классам?

На основе ветки здесь вроде исправили.

person James Strachan    schedule 06.11.2008
comment
Банка починила это. (точнее, довел меня до другой проблемы). - person JeffV; 06.11.2008