用于标头评估的 Spring Integration SpEL

Question

我正在尝试使用 SpEL 评估 Spring Integration 消息的 JMSHeader，但它似乎总是评估为 false，即使消息标头标记为 true

<si:router expression="headers.jms_redelivered.equals(T(java.lang.Boolean).FALSE) ? 'channel1' : 'channel2' />

JMSXDeliveryCount=10, jms_redelivered=true

有人可以评论我在这里做错了什么吗？

谢谢

Answer 1

为我工作：

@Test
public void testRedeliveredHeaderWithSpEL() throws JMSException {
    DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
    javax.jms.Message jmsMessage = new StubTextMessage() {
        @Override
        public boolean getJMSRedelivered() throws JMSException {
            return true;
        }
    };
    Map<String, Object> headers = mapper.toHeaders(jmsMessage);
    assertNotNull(headers.get(JmsHeaders.REDELIVERED));

    SpelExpressionParser parser = new SpelExpressionParser();
    StandardEvaluationContext context = new StandardEvaluationContext();
    context.addPropertyAccessor(new MapAccessor());
    Expression expression =
            parser.parseExpression("jms_redelivered.equals(T(java.lang.Boolean).FALSE) ? 'channel1' : 'channel2'");
    assertEquals("channel2", expression.getValue(context, headers, String.class));

}

您确实应该确保在您的<router> 之前不会丢失headers。

也许你在<router> 之前使用了一些<transformer>，它返回整个Message<?> 而不是payload？