I have configured spring boot so that command bus will be distributed, as discovery client, I use kubernetes client. Everything seems to be working well, pods and endpoints beeing recognized.
Codewise, I have a saga that begins with a rest call, and ends with one also . As routing strategy: AnnotationRoutingStrategy. Everyting works well until now.
First call, the one who starts saga is successful, the second one also, only thing is that is not routed on the correct pod/endpoint.
All segments seem to be local, and all calls also (I have an AOP logger that logs Member types).
ConsistentHash class seems to be the problem here, method is getMember(Stiring routingKey, CommandMessage commandMessage) - and selecting the segment seems to be based on command name, not routing key…or maybe I’m missing something…