发送到 camel hazelcast seda 端点时丢失 headers

Question

我使用带有 hazelcast 组件的 camel 并在交换通过 hazelcast seda 时遇到交换问题 headers。

我需要从目录中轮询文件并将交换发送到 seda hazelcast queue（在集群中处理交换）。

这种情况有一个简单的例子。有两条路由，运行在其他JVM中：

第一个轮询文件：

from("file:someFromFolder")
        .to("hazelcast:seda:queue?hazelcastInstance=#hazelcast-instance");

第二个处理这个：

from("hazelcast:seda:queue?hazelcastInstance=#hazelcast-instance")
        .to("file:someToFolder");

当我尝试像 Exchange.FILE_NAME 或其他人一样阅读 headers 时，我发现它们是空的。

在通过 hazelcast seda 组件转移交易时是否可以节省 headers？

编辑

当我将 transferExchange=true 设置为生产者路由端点上的选项时，我捕获到异常：

Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
org.apache.camel.RuntimeExchangeException: Message body of type org.apache.camel.component.file.GenericFile is not supported by this marshaller. on the exchange: Exchange[ID-DF-240815-MS12-60568-1487853045890-0-12][file.txt]
                at org.apache.camel.impl.DefaultExchangeHolder.marshal(DefaultExchangeHolder.java:99)
                at org.apache.camel.impl.DefaultExchangeHolder.marshal(DefaultExchangeHolder.java:83)
                at org.apache.camel.component.hazelcast.seda.HazelcastSedaProducer.checkAndStore(HazelcastSedaProducer.java:55)
                at org.apache.camel.component.hazelcast.seda.HazelcastSedaProducer.process(HazelcastSedaProducer.java:42)
                at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:141)
                at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
                at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)
                at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
                at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
                at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
                at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
                at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:442)
                at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:214)
                at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:178)
                at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:174)
                at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:101)
                at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
                at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
                at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access1(ScheduledThreadPoolExecutor.java:180)
                at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
                at java.lang.Thread.run(Thread.java:745)

那么会不会是 marshaller 尝试序列化所有文件数据？

Answer 1

您需要将 transferExchange=true 设置为端点上的选项。默认情况下，它只是传输的消息正文。您可以在文档中找到此信息：http://camel.apache.org/hazelcast-component.html#HazelcastComponent-seda

发送到 camel hazelcast seda 端点时丢失 headers

Lose headers when send to camel hazelcast seda endpoint

apache-camel

hazelcast