docs: @Override
      public int queueSize() {
          try (Channel channel = createChannel()) {
              return channel.queueDeclarePassive(getQueueName()).getMessageCount();
          } catch (Exception e) {
              throw e instanceof QueueException ? (QueueException) e : new QueueException(e);
          }
      }