How to get List<String> in RedisPubSubListener.message?

[v-chernyshev]

Good afternoon,

I'm trying to implement RESP2-based client-side caching support using lettuce, and currently have this code in place to test the cache invalidation events:

final var client = RedisClient.create(uriBuilder.build());
client.setOptions(ClientOptions.builder().protocolVersion(ProtocolVersion.RESP2).build());

final var pubSub = client.connectPubSub();
final var tracking = TrackingArgs.Builder.enabled().redirect(pubSub.sync().clientId()).bcast();

final var data = client.connect();
data.sync().clientTracking(tracking);

pubSub.addListener(new RedisPubSubAdapter<>() {
    @Override
    public void message(String channel, String message) {
        System.out.printf("Channel: %s, Message: %s%n", channel, message);
    }
});

pubSub.sync().subscribe("__redis__:invalidate");

Everything is fine for commands that modify single keys, e.g. SET foo bar results in Channel: __redis__:invalidate, Message: foo printed. Multi-key commands, however, don't behave as I expect. For MSET foo bar baz qux the above code only produces Channel: __redis__:invalidate, Message: foo. The baz invalidation event is effectively lost. Here is the output of redis-cli for comparison:

1) "message"
2) "__redis__:invalidate"
3) 1) "baz"
   2) "foo"

Could you please advise how to get the list of all the affected keys in the listener?

[tishun]

Hey @v-chernyshev ,

Thanks for logging this and thanks for providing a reproducer to test it.

Please allow the team some time to analyse the problem and we will get back to you ASAP