docs: protected Channel getConsumerChannel() throws IOException, TimeoutException {
          if (consumerChannel == null) {
              synchronized (this) {
                  if (consumerChannel == null) {
                      consumerChannel = createChannel();
                  }
              }
          }
          return consumerChannel;
      }