docs: public void  put(MessageExchange messageExchange) throws InterruptedException, BufferStoppedException {
          synchronized (status) {
              if (status.isRunning()) {
                  requests.put(messageExchange);
                  listener.valuesChanged(this, consumersIdle(), requestsWaiting());
                  diagnose("Put one request into buffer.");
              } else {
                  throw new BufferStoppedException();
              }
          }
      }