Hazelcast-忽略本地消息

问题描述 投票:0回答:1

对于特定的用例,我需要发布到ITopic,并且还使用Hazelcast客户端(而非实例)使用来自同一ITopic的消息。但是,我不希望在本地处理在该主题上生成的消息,即同一组件不应生成并使用其自己的消息。

对于JMS,有一项规定可以忽略本地消息。但是,我没有为Hazelcast ITopic找到这样的选项。

作为一种变通方法,我尝试比较Message.getMember()。getUUID和HazelcastInstance.localEndpoint()。getUUID(),以查看它们是否相同。它们不相同(以某种方式,我不希望它们与客户端服务器设置相同)。

现在的问题是,Hazelcast API中是否可以使用任何机制来忽略本地消息?还是我必须基于组件/客户端维护消息标签并过滤消息。

任何帮助将不胜感激。

messaging hazelcast
1个回答
0
投票

Topic背后的想法将被分发,并且任何消费者都可以订阅事件。因此,不存在局域性。

恐怕您需要在消息中添加其他标识您的节点的元数据,并基于该数据设置过滤器。

© www.soinside.com 2019 - 2024. All rights reserved.