docs: protected Queue<IQueueMessage<ID, DATA>> createQueue(int boundary) {
          if (boundary > 0) {
              if (boundary > 1024) {
                  return new LinkedBlockingQueue<>(boundary);
              } else {
                  return new ArrayBlockingQueue<>(boundary);
              }
          } else {
              return new ConcurrentLinkedQueue<>();
          }
      }