code: public DisruptorQueue<ID, DATA> init() throws Exception {
          /* single producer "seems" to offer better performance */
          ringBuffer = RingBuffer.createSingleProducer(EVENT_FACTORY, ringSize);
          // ringBuffer = RingBuffer.createMultiProducer(EVENT_FACTORY, ringSize);
  
          if (!isEphemeralDisabled()) {
              int ephemeralBoundSize = Math.max(0, getEphemeralMaxSize());
              ephemeralStorage = new ConcurrentHashMap<>(
                      ephemeralBoundSize > 0 ? Math.min(ephemeralBoundSize, ringSize) : ringSize);
          }
  
          consumedSeq = new Sequence();
          ringBuffer.addGatingSequences(consumedSeq);
          long cursor = ringBuffer.getCursor();
          consumedSeq.set(cursor);
          knownPublishedSeq = cursor;
  
          super.init();
  
          return this;
      }
docs: Init method.
  
  @return
  @throws Exception