Производители и потребители Apache Camel
У меня возникают трудности с обдумыванием концепции.
Я пытаюсь реализовать конечную точку, которая прослушивает tcp-порт для входящих сообщений в частном формате, который затем преобразовал бы сообщение и позволил бы верблюду переадресовать и выполнить маршрутизацию.
Правильно ли я понял, что производитель отвечает за отправку сообщений вEndpoint
иConsumer
получает их с этой конечной точки?
При изучении интерфейсов я не мог понять поток сообщений между этими объектами, особенно на стороне потребителя.Consumer
только определяетstart()
а такжеstop()
методы ...
При настройке теста на реализацию скелета,Camel
вызываетсяcreateProducer()
на конечной точке иprocess()
на объекте производителя. После этого он вернулся, не делая ничего с потребителем или процессором, связанным с ним.
Может ли кто-нибудь указать мне правильное направление?