jbpm4 jms

可以配置一个真实的JMS，确保可以通过JNDI查找到它， jms活动也可以使用模拟的JMS提供器来进行测试。 这样就更容易进行你的流程测试。

下面的测试帮助方法是基于单独的在原始的JMS api上实现，因此它们 也可以工作在标准工作环境里，就想在一个appserver环境里一样：

比如，在流程执行完jms活动以后， 消息可以像这样进行验证：

MapMessage mapMessage = (MapMessage)
  jmsConsumeMessageFromQueue("java:/JmsXA", "queue/ProductQueue");
assertEquals("shampoo", mapMessage.getString("product"));

下面的jms帮助方法是基于mockrunner的， 因此它们只工作在单独运行环境中：

（我们使用mockrunner协同工作，人们也可以让这些方法工作在appserver环境下）

比如，一个队列可以被创建和删除，在一个测试的setup和teardown方法中，像这样：

protected void setUp() throws Exception {
  super.setUp();
  jmsCreateQueue("java:/JmsXA", "queue/ProductQueue");
}

protected void tearDown() throws Exception {
  jmsRemoveQueue("java:/JmsXA", "queue/ProductQueue");
  super.tearDown();
}

第一个可以发送的JMS消息是使用文本作为载体。这种情况下 一个JMS TextMessage会被创建，并发送给指定的目的地。 参考下面的流程定义：

<process name="JmsQueueText">

  <start>
    <transition to="send message"/>
  </start>

  <jms name="send message"
       connection-factory="java:JmsXA"
       destination="queue/jbpm-test-queue"
       transacted="false">
    <text>This is the body</text>
    <transition to="wait"/>
  </jms>

  <state name="wait"/>

</process>

像你期待的一样，下面的测试用例中启动这个流程会导致 JMS节点发送一个消息到队列，使用"queue/jbpm-test-queue"名称。 用来创建连接的工厂来连接这个名为"Java:JmsXA"的队列。 消息的载体是文本"This is the body"。

executionService.startProcessInstanceByKey("JmsQueueText");

TextMessage textMessage = (TextMessage)
  jmsConsumeMessageFromQueue("java:JmsXA", "queue/jbpm-test-queue", 1000, false, Session.AUTO_ACKNOWLEDGE);
assertEquals("This is the body", textMessage.getText());

对应的代码在上面用粗体显示了。方法的其余部分是样板代码，需要设置一个消息消费者。 我们会在其他子章节中的例子中忽略这些代码。

第二个可选的是使用序列化对象作为消息的载体。 在这种情况下，一个JMS ObjectMessage会被创建和发送给指定的目的地。 参考下面的流程定义：

<process name="JmsQueueObject">

  <start>
    <transition to="send message"/>
  </start>

  <jms name="send message"
       connection-factory="java:JmsXA"
       destination="queue/jbpm-test-queue"
       transacted="false">
    <object expr="${object}"/>
    <transition to="wait"/>
  </jms>

  <state name="wait"/>

</process>

像上面例子中，消息会被发送到名为"queue/jbpm-test-queue"的队列。 也是使用了名为"Java:JmsXA"的连接工厂 来创建连接，并连接到队列。但是在这种情况下，消息的载体是序列化的对象， 通过执行expr属性中定义的表达式来获得这个对象。这个例子如下所示。

Map<String, Object> variables = new HashMap<String, Object>();
variables.put("object", "this is the object");
executionService.startProcessInstanceByKey("JmsQueueObject", variables);

ObjectMessage objectMessage = (ObjectMessage)
  jmsConsumeMessageFromQueue("java:JmsXA", "queue/jbpm-test-queue", 1000, false, Session.AUTO_ACKNOWLEDGE);
assertEquals("this is the object", objectMessage.getObject());

第三个可能的载体是map的key-value结构。这次，一个JMS MapMessage 会被创建，发送到指定目的地。 参考下面的流程定义：

<process name="JmsQueueMap">

  <start>
    <transition to="send message"/>
  </start>

  <jms name="send message"
       connection-factory="java:JmsXA"
       destination="queue/jbpm-test-queue"
       transacted="false">
    <map>
      <entry>
        <key><string value="x"/></key>
        <value><string value="foo"/></value>
      </entry>
    </map>
    <transition to="wait"/>
  </jms>

  <state name="wait"/>

</process>

一个消息会被发送到名为"queue/jbpm-test-queue"的队列， 并且使用名为"Java:JmsXA"的工厂创建连接，链接到队列。 在这种情况，消息的载体是特定的key-value map。 这个例子如下所示。

executionService.startProcessInstanceByKey("JmsQueueMap");

MapMessage mapMessage = (MapMessage)
  jmsConsumeMessageFromQueue("java:JmsXA", "queue/jbpm-test-queue", 1000, false, Session.AUTO_ACKNOWLEDGE);
assertTrue(mapMessage.itemExists("x"));
assertEquals("foo", mapMessage.getObject("x"));