您可以使用 Bean 集成在 bean 上调用方法,并使用各种语言(如 JSonPath)从消息中提取值并将其绑定到 method 参数。
例如:
public class Foo {
@Consume(uri = "activemq:queue:books.new")
public void doSomething(@JsonPath("$.store.book[*].author") String author, @Body String json) {
// process the inbound message here
}
}