code: public static <K, V> QueueListenerFactory<K, V> create(DisqueURI disqueURI, RedisCodec<K, V> codec, K... queues) {
          return new QueueListenerFactory<K, V>(Schedulers.io(), disqueURI, codec, queues);
      }
docs: Create a new {@link QueueListenerFactory}. The default {@link Schedulers#io()} scheduler is used for listener
  notification and I/O operations.
  
  @param disqueURI the DisqueURI
  @param codec use this codec to encode/decode keys and values, must note be {@literal null}
  @param queues the queue names
  @param <K> Key type
  @param <V> Value type
  @return a new instance of {@link QueueListenerFactory}