我很难理解这个概念。
我正在尝试实现一个端点,它在 tcp 端口上侦听专有格式的传入消息,然后将转换消息并让骆驼接管转发和路由。
我是否正确理解生产者负责将消息发送到该端点Endpoint
并Consumer
从该端点接收它们?
在研究接口时,我无法弄清楚这些对象之间的消息流,尤其是在消费者部分。Consumer
只定义start()
和stop()
方法...
在对骨架实现设置测试时,在端点和生产者对象上Camel
调用。之后它返回,没有对消费者或与之关联的处理器做任何事情。createProducer()
process()
有人能指出我正确的方向吗?