code: private void destroy() {
          if (queue != null) {
  
              if (!queue.isEmpty()) {
                  logger.trace("Non-empty queue: {}", queue);
  
                  if (releaseMessages) {
                      Object msg;
                      while ((msg = queue.poll()) != null) {
                          ReferenceCountUtil.safeRelease(msg);
                      }
                  }
              }
  
              queue.recycle();
              queue = null;
          }
      }
docs: Releases all messages and destroys the {@link Queue}.