code: public boolean isRunning(String logicalQueueName) {
  		Future<?> future = this.scheduledFutureByQueue.get(logicalQueueName);
  		return future != null && !future.isCancelled() && !future.isDone();
  	}
docs: Checks if the spinning thread for the specified queue {@code logicalQueueName} is
  still running (polling for new messages) or not.
  @param logicalQueueName the name as defined on the listener method
  @return {@code true} if the spinning thread for the specified queue is running
  otherwise {@code false}.