code: @Nullable
      private DedupQueue getQueueReadWrite(String queue, Duration waitDuration) {
          return _ownerGroup.startIfOwner(queue, waitDuration);
      }
docs: Returns the mutable persistent sorted queue if managed by this JVM, {@code null} otherwise.