如何在Apache Camel中通过JMS队列传递POJO

Question

我对Jboss Fuse相对较新

<route id="fileRoute">
        <from uri="file:{{PFlowIn_AEROW}}?delay={{PFlowScanDelay}}&amp;filter=#fileFilter&amp;delete=true"/>                 
        <process ref="saveFlowParamsInPOJO"/>
        <recipientList>
            <simple>activemq:queue:databaseQueue, activemq:queue:messageArchiveQueue, activemq:queue:XmlValidationQueue</simple>
        </recipientList>
    </route>

Answer 1

将您的POJO转换为数据交换格式（例如json）并保存到标头中

1. 将POJO转换为json字符串
2. 将json字符串保存到消息头
3. 将json字符串转换为POJO或map

您可以导入apache camel json组件中可用的json库，然后执行封送/解封。

如果希望在bean中转换POJO，还可以尝试使用Jackson ObjectMapper类进行转换。

// Convert from POJO to json String
ObjectMapper objectMapper = new ObjectMapper();
String pojoAsString = objectMapper.writeValueAsString(yourPojo);

// Convert from json String to POJO
YourPojo yourPojo = objectMapper.readValue(pojoAsString , YourPojo.class);

// convert from json String to map
Map<String, Object> map = objectMapper.readValue(pojoAsString , new TypeReference<Map<String,Object>>(){});

上述ObjectMapper示例的来源

Answer 2

据我所知，您只能在消息体中设置一个对象，但您有两个选项。

>

exchange.getIn().setHeader("myPOJO", POJOvalue);

编辑：

正如@BeenaRautela所指出的，建议的第二个选项无效，因为标头只接受非对象数据类型。

其他选项包括：

• 在消息正文中发送POJO并尝试将XML作为标题中的字符串发送。
• 将POJO参数存储在Map中并将其设置在标头中。