Я пытаюсь настроить простую демонстрацию activemq и mina. Я отредактировал camelContext в файле activemq.xml, включив в него два минимальных сокета 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
Нужно ли мне явно добавлять мина-бин? Если да, то где и как?