search

spring-projects / spring-integration-extensions

The Spring Integration Extensions project provides extension components for Spring Integration
http://www.springintegration.org/
281 stars 266 forks source link

CacheListeningPolicyType.ALL not working when using ITopic #194

Closed ttomttom closed 6 years ago

ttomttom commented 6 years ago

Messages published to an ITopic are being received by local hazelcast member only, all remote members receive the message but they discard it even when CacheListeningPolicyType.ALL is set by the HazelcastEventDrivenMessageProducer

HazelcastMessageListener is ignoring the currently set CacheListeningPolicyType and just calls sendMessage with null here:

https://github.com/spring-projects/spring-integration-extensions/blob/0ba841416b9f7f54e29a958172ba7bb2b0e13392/spring-integration-hazelcast/src/main/java/org/springframework/integration/hazelcast/inbound/HazelcastEventDrivenMessageProducer.java#L171

Any reason why this shouldn't pass the CacheListeningPolicyType?

artembilan commented 6 years ago

This is just an omission I guess.

Good catch!

The latest 1.0.1.BUILD-SNAPSHOT contains the fix.

Thank you for the feedback!