从 jms 队列到 Servicemix 6 (ActiveMQ) 中自定义 class 的骆驼路线
Camel route from jms queue to custom class in Servicemix 6 (ActiveMQ)
我想创建一条从 jms 到可以接收 TextMessage 的 POJO 的骆驼路线。
现在我路由到这样的 bean:
from("jms:person_queue").to("bean:QueueConsumerBean?method=consume")
然后我在我的 bean 方法中收到一个字符串。我宁愿使用带有 "onMessage" 方法和 TextMessage 的自定义 class。原因是我想对消息使用客户端确认,就像交易一样。
或者有其他使用客户端ack的方法吗?
Camel 的 JMS 消费者会自动为您处理 ack 类型。如果路由成功,它将确认消息。如果没有(即..交换命中异常处理程序)它将回滚。
重要警告:CLIENT_ACKNOWLEDGE 的行为不直观。根据 JMS 规范。它会确认会话中的当前消息和所有之前的消息。这 不能 被认为是每条消息的确认。如果你需要每条消息的确认.. 使用 TRANSACTED.
我想创建一条从 jms 到可以接收 TextMessage 的 POJO 的骆驼路线。 现在我路由到这样的 bean:
from("jms:person_queue").to("bean:QueueConsumerBean?method=consume")
然后我在我的 bean 方法中收到一个字符串。我宁愿使用带有 "onMessage" 方法和 TextMessage 的自定义 class。原因是我想对消息使用客户端确认,就像交易一样。
或者有其他使用客户端ack的方法吗?
Camel 的 JMS 消费者会自动为您处理 ack 类型。如果路由成功,它将确认消息。如果没有(即..交换命中异常处理程序)它将回滚。
重要警告:CLIENT_ACKNOWLEDGE 的行为不直观。根据 JMS 规范。它会确认会话中的当前消息和所有之前的消息。这 不能 被认为是每条消息的确认。如果你需要每条消息的确认.. 使用 TRANSACTED.