Rejects a message. A rejected message can be requeued or
 dropped by RabbitMQ.

 @param [Integer] delivery_tag Delivery tag to reject
 @param [Boolean] requeue      Should this message be requeued instead of dropping it?

 @return nil
 @api public
773143
def reject(delivery_tag, requeue = false)
      if @acknowledged_state[:pending].key?(delivery_tag)
        delivery, header, body = update_acknowledgement_state(delivery_tag, :rejected)
        delivery.queue.publish(body, header.to_hash) if requeue
      end
      nil
    end
1143709
def rejected? label, reject
      if reject.any? && (x = reject.first[:except])
        if x.is_a?(Array)
          return true if x.find {|m| match?(label, m)}
        else
          return true if match?(label, x)
        end
      end
      false
    end
850663
@Override
  protected boolean reject(LogItem log) {
    if (blacklistTags != null) {
      for (String disabledTag : blacklistTags) {
        if (log.tag.equals(disabledTag)) {
          return true;
        }
      }
    }
    return false;
  }
493504
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        if (executor.isShutdown()) {
            throw new RejectedExecutionException();
        }
        
        final BlockingQueue<Runnable> poolQueue = executor.getQueue();
        if (LOG.isDebugEnabled()) {
            LOG.debug("Putting Runnable into BlockingQueue(size=" + poolQueue.size() + ") directly and potentially waiting due to executor rejection");
        }
        
        try {
            poolQueue.put(r);
            if (LOG.isDebugEnabled()) {
                LOG.debug("Put Runnable into BlockingQueue(size=" + poolQueue.size() + ") directly due to executor rejection");
            }
        }
        catch (InterruptedException e) {
            throw new RejectedExecutionException("Interrupted while waiting to queue Runnable", e);
        }
    }
277968
public function ack($deliveryTag = 0, $multiple = false)
    {
        return $this->getClient()->ack($this->getChannelId(), $deliveryTag, $multiple);
    }
688384
public function acknowledge($delivery_tag, $type = 1)
    {
        if ($type == 1) {
            //确认消息
            return $this->amqpQueue->ack($delivery_tag);
        } elseif ($type == 2) {
            //恢复消息
            return $this->amqpQueue->nack($delivery_tag);
        } elseif ($type == 3) {
            //确认取消
            return $this->amqpQueue->reject($delivery_tag);
        } else {
            throw new \AMQPQueueException('Undefined Acknowledge type');
        }
    }
943686
def __accept_reject(self, prompt, accepted_text, rejected_text, display_rejected):
        """"""
        accept_event = threading.Event()
        result_ref = [False]

        def perform():
            def accepted():
                result_ref[0] = True
                accept_event.set()

            def rejected():
                result_ref[0] = False
                accept_event.set()

            self.__message_column.remove_all()
            pose_confirmation_message_box(self.ui, self.__message_column, prompt, accepted, rejected, accepted_text, rejected_text, display_rejected)
            #self.__message_column.add(self.__make_cancel_row())

        with self.__lock:
            self.__q.append(perform)
            self.document_controller.add_task("ui_" + str(id(self)), self.__handle_output_and_q)
        accept_event.wait()
        def update_message_column():
            self.__message_column.remove_all()
            self.__message_column.add(self.__make_cancel_row())
        self.document_controller.add_task("ui_" + str(id(self)), update_message_column)
        return result_ref[0]
1007923
@Override
  protected boolean reject(LogItem log) {
    if (whitelistTags != null) {
      for (String enabledTag : whitelistTags) {
        if (log.tag.equals(enabledTag)) {
          return false;
        }
      }
    }
    return true;
  }
1079208
public void reject(final String errorCode, final Map<String, Object> messageVariables, final String defaultMessage) {
        reject(new String[]{errorCode}, messageVariables, defaultMessage);
    }
100589
def start
      channel.prefetch(10)
      queue.subscribe(manual_ack: true, exclusive: false) do |delivery_info, metadata, payload|
        begin
          body = JSON.parse(payload).with_indifferent_access
          status = run(body)
        rescue => e
          status = :error
        end

        if status == :ok
          channel.ack(delivery_info.delivery_tag)
        elsif status == :retry
          channel.reject(delivery_info.delivery_tag, true)
        else # :error, nil etc
          channel.reject(delivery_info.delivery_tag, false)
        end
      end

      wait_for_threads
    end
350160
public function sendNack($requeue = false)
    {
        $this->amqpMessage->delivery_info['channel']->basic_nack(
            $this->getDeliveryTag(),
            true, // ignore all unacknowledged messages
            $requeue // reschedule the message
        );
    }
477330
def try(*args, &block)
      case
      when args.empty? && block_given?
        yield self
      when respond_to?(args.first)
        __send__(*args, &block)
      else
        @tag.try(*args, &block)
      end
    end
857246
function reject(err, async) {
    err = toErr(err);
    if (async) {
        return Promise.reject(err);
    } else {
        throw err;
    }
}
775415
function reject(vReason) {
			vResult = vReason;
			iState = -1;

			if (!bCaught && SyncPromise.listener) {
				SyncPromise.listener(that, false);
			}

			if (fnReject) {
				fnReject(vReason);
				fnReject = fnResolve = null; // be nice to the garbage collector
			}
		}
137897
public function reject(AMQPMessage $message, $requeue = false)
    {
        $message->delivery_info['channel']->basic_reject($message->delivery_info['delivery_tag'], $requeue);
    }
427499
public function basic_ack($delivery_tag, $multiple = false)
    {
        list($class_id, $method_id, $args) = $this->protocolWriter->basicAck($delivery_tag, $multiple);
        $this->send_method_frame(array($class_id, $method_id), $args);
    }
217132
public static function requeue(int $deliveryTag): self
    {
        $self = new self($deliveryTag);
        $self->requeue = true;

        return $self;
    }