Apache Camel--Websphere MQ集成

Question

我有一个使用apache-camel解决方案的应用程序，希望通过jms将消息发送到Websphere MQ Server，将jms属性jms_ibm_mqmd_msgid转换为MQMD字段MQMD.msgid，以便通过camel在消息上设置该值

exchange.getIn().setHeader(WMQConstants.JMS_IBM_MQMD_MSGID, "XXXXXXXXXXXXXXXXXXXXXXXX".getBytes());

根据Apache Camel-IBM MQ集成，我们似乎需要在目标对象上设置另一个属性。在http://camel.apache.org/JMS.html上，我为camel JMS组件提供了一个自定义的DestinationResolver，为目标对象提供了MDWriteEnabled、MDREADEnabled。

<bean id="ibmMQServer01" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="ibmMQCredentialConnectionFactory01" />
    <property name="destinationResolver" ref="wmqDestinationResolver" />
</bean>

和

public class WMQDestinationResolver implements DestinationResolver {
    @Override
    public Destination resolveDestinationName(Session session, String destinationName, 
            boolean pubSubDomain) throws JMSException {
        MQSession mqSession = (MQSession) session;
        MQQueue queue = (MQQueue) mqSession.createQueue("queue:///" + destinationName);
        queue.setBooleanProperty(WMQConstants.WMQ_MQMD_WRITE_ENABLED, true);
        queue.setBooleanProperty(WMQConstants.WMQ_MQMD_READ_ENABLED, true);
        queue.setIntProperty(WMQConstants.WMQ_MQMD_MESSAGE_CONTEXT, WMQConstants.WMQ_MDCTX_SET_ALL_CONTEXT);
        return queue;
    }
}

收到的JMSMessageID是ID:414d512043532e51412e434253412e511987055902cc6222，可以将其解析为上面的杂乱字符串。

Answer 1

我钻取camel代码并找到根实例

在设置jms属性时，它将运行org.apache.camel.component.jms.jmsbinding的方法GetValidJMSheaderValue

protected Object getValidJMSHeaderValue(String headerName, Object headerValue) {
    if (headerValue instanceof String) {
        return headerValue;
    } else if (headerValue instanceof BigInteger) {
        return headerValue.toString();
    } else if (headerValue instanceof BigDecimal) {
        return headerValue.toString();
    } else if (headerValue instanceof Number) {
        return headerValue;
    } else if (headerValue instanceof Character) {
        return headerValue;
    } else if (headerValue instanceof CharSequence) {
        return headerValue.toString();
    } else if (headerValue instanceof Boolean) {
        return headerValue;
    } else if (headerValue instanceof Date) {
        return headerValue.toString();
    }
    return null;
}

似乎camel拒绝字节数组值并返回null，因此jms提供程序无法应用jms_ibm_mqmd_msgid的属性。我重写了这个方法以使其恢复。