首页 > 解决方案 > 测试用例java中的骆驼确认

问题描述

我在项目中有一个骆驼配置,如下所示:

from("jmsDestinationUri")
        .id("DataWriteRoute")
        .autoStartup(consumerActive)
        .process(exchange -> fileHandler.dumpMessageToDisk(exchange))
        .unmarshal(new JsonDataFormat(JsonLibrary.Jackson) {{ setUnmarshelType(MyBean.class)}})
        .process(feedProcessor)
        .log("records successfully written to DB.");

我从我的测试类中调用它,如下所示:

jmsTemplate.send("jmsDestinationUri", new MessageCreator() {

  @Override
  public javax.jms.Message createMessage(Session session) throws JMSException {
    BytesMessage bytesMessage = session.createBytesMessage();
    bytesMessage.writeBytes(message.getBytes());
    return bytesMessage;
  }
});

该类正在转换 JSON 消息,对其进行丰富并持久化到 DB。

如果路由中的处理方法完成与否,有什么方法可以收集确认?我必须对持久保存到数据库的数据进行断言。

标签: javajunitapache-camel

解决方案


推荐阅读