<dependency> <groupId>com.github.davidmarquis.redisq</groupId> <artifactId>rx-redisq-java</artifactId> <version>1.0.0</version> </dependency> String redisHost = "127.0.0.1"; int redisPort = 6379; RedisClient redisClient = RedisClient.create(RedisURI.create(redisHost, redisPort)); redisClient.getCommander() .rxEnqueue(queueName, element) .subscribe(result -> System.out.println("Element enqueued successfully: " + result)); redisClient.getCommander() .rxDequeue(queueName) .subscribe(element -> System.out.println("Dequeued element: " + element)); String key = "myKey"; redisClient.getCommander() .rxGet(key) .subscribe(value -> System.out.println("Value for key " + key + ": " + value)); redisClient.shutdown();