code: public static <K, V> QueueListenerFactory<K, V> create(Scheduler scheduler, DisqueURI disqueURI, RedisCodec<K, V> codec,
              K... queues) {
          return new QueueListenerFactory<K, V>(scheduler, disqueURI, codec, queues);
      }
docs: Create a new {@link QueueListenerFactory}. The provided {@code scheduler} is used for listener notification and I/O
  operations.
  
  @param scheduler a scheduler from rxjava for 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}