20.6. 示例
例如,要测试将一组消息发送到队列,然后从队列中消耗,而不丢失任何消息:
// send the dataset to a queue from("dataset:foo").to("activemq:SomeQueue"); // now lets test that the messages are consumed correctly from("activemq:SomeQueue").to("dataset:foo");
以上会在 Registry 中查找用于创建消息的 foo DataSet 实例。
然后,您可以创建一个 DataSet 实现,例如使用 SimpleDataSet
,配置数据集的大事项,以及消息样子等。