Apache Camel调用Hazelcast后无法获取自定义Header/Property求助

这是个很常见的问题，核心原因在于Camel Hazelcast组件的事件消息机制：当你通过hazelcast:map:testMap发送put操作时，发送路由的Exchange上下文（包括自定义Header和Property）和后续触发接收路由的Exchange是完全隔离的。Hazelcast的事件（比如entryAdded）只会传递数据本身以及组件内置的元信息（如CamelHazelcastEventType、CamelHazelcastObjectId），不会自动复制你设置的自定义内容。

下面给你两种可行的解决方案：

方案一：将自定义数据嵌入到存入Hazelcast的对象中 #

这是最直接的方法——把你的自定义test值和业务数据一起封装成一个对象，存入Hazelcast Map。接收路由从这个对象中提取需要的信息。

步骤1：创建包装类（Java示例） #

public class DataWithMeta {
    private String payload; // 你的业务数据
    private String test; // 自定义的test值

    // 构造函数、getter、setter省略
}

步骤2：修改发送路由 #

把包装后的对象存入Map：

<route>
    <from uri="..."/>
    <setHeader headerName="CamelHazelcastObjectId">
        <constant>123</constant>
    </setHeader>
    <setHeader headerName="CamelHazelcastOperationType">
        <constant>put</constant>
    </setHeader>
    <!-- 构造包含自定义数据的对象 -->
    <bean method="createDataWithMeta">
        <argument value="test"/> <!-- 自定义test值 -->
        <argument>${body}</argument> <!-- 原业务数据 -->
    </bean>
    <to uri="hazelcast:map:testMap"/>
</route>

步骤3：修改接收路由 #

从对象中提取自定义值：

<route>
    <from uri="hazelcast:map:testMap"/>
    <log message="printing:::: ${body.test}"/>
    <to uri="..."/>
</route>

方案二：自定义Hazelcast EntryListener传递属性 #

如果你不想修改业务对象，可以通过扩展Hazelcast的EntryListener，在触发事件时手动将自定义属性注入到Camel的Exchange Header中。

步骤1：实现自定义EntryListener #

public class CustomEntryListener extends EntryAdapter<String, Object> {
    @Override
    public void entryAdded(EntryEvent<String, Object> event) {
        // 这里可以获取需要传递的元数据，比如你可以在存入时把test值存在Hazelcast的EntryAttribute里
        String testValue = (String) event.getEntry().getAttribute("test");
        // 通过Camel的Hazelcast组件API将属性传递给Exchange
        // 具体实现需要结合Camel Hazelcast组件的扩展机制，比如自定义Component或Endpoint
    }
}

步骤2：注册自定义Listener到Hazelcast Map #

在Camel路由或Hazelcast配置中注册这个Listener，确保事件触发时能将自定义属性注入到Exchange中。

补充说明 #

Camel Hazelcast组件的事件消息默认只包含以下内置Header：

• CamelHazelcastEventType：事件类型（如ADDED、UPDATED）
• CamelHazelcastObjectId：操作的对象ID
• CamelHazelcastOperationType：操作类型（如PUT、GET）

自定义的Header/Property不会自动传递，所以必须通过上述两种方式手动处理。

内容的提问来源于stack exchange，提问作者anonymous