How to use Redis pipelining?

Viewed 27

I would like to know how to use/control the Quarkus reactive Redis client with pipelining (ReactiveRedisDataSource). I understand the client does pipelining by default, but how can we control how many commands are pipelined before the request is sent? For example:

    @Inject
    ReactiveRedisDataSource reactiveDS;
    
    // some code below ...
    
    reactiveDS.list(String.class).lpush("myList", "randomString")
      .chain(() -> reactiveDS.hash(String.class).hset("myKey", "field1", "randomValue"))

Does the code above pipelines those 2 commands? If not then how can I pipeline? If yes, how can I control how many messages can I enqueue before sending and how can I get the array response?

0 Answers
Related