Sends a negative acknowledgment
@param bool $requeue Will the message be requeued
350160
public function sendNack($requeue = false)
    {
        $this->amqpMessage->delivery_info['channel']->basic_nack(
            $this->getDeliveryTag(),
            true, // ignore all unacknowledged messages
            $requeue // reschedule the message
        );
    }
1141751
public function nack($multiple = null, $requeue = null)
    {
        $this->checkChannel();

        $outputFrame = BasicNackFrame::create($this->tag, $multiple, $requeue);
        $outputFrame->frameChannelId = $this->channel->getId();
        $this->channel->getConnection()->command($outputFrame);
    }
771644
public function pass(CommitMessage $msg) : bool
    {
        if (!$msg->isEmpty()) {
            $firstLetter = substr($msg->getSubject(), 0, 1);
            return $firstLetter === strtoupper($firstLetter);
        }
        return false;
    }
1339245
public function nack(Message $message, $requeue = false)
    {
        $protocol = $this->client->getProtocol();
        if (null === $protocol) {
            throw new StompException('Stomp protocol is require to NACK Frames.');
        }

        $this->client->sendFrame(
            $protocol->getNackFrame(
                new StompMessage($message->getBody(), $message->getProperties()),
                null,
                $requeue
            ),
            false
        );
    }
1305773
public function setKeepalive($bool)
    {
        $this->keepalive = (bool)$bool;
        $this->setOption(\EventUtil::SOL_SOCKET, \EventUtil::SO_KEEPALIVE, $this->keepalive ? true : false);
    }
1236100
public function basicReject($deliveryTag, $reQueue)
    {
        $args = new Writer();
        $args->writeLongLong($deliveryTag)
            ->writeBit($reQueue);
        return $args;
    }
238126
public function badRequest($req)
    {
        $this->state = self::STATE_ROOT;
        $this->write("400 Bad Request\r\n\r\n<html><head><title>400 Bad Request</title></head><body bgcolor=\"white\"><center><h1>400 Bad Request</h1></center></body></html>");
        $this->finish();
    }
1052403
public function markFailed($notify = true) {
		$this->Status = 'Failed';
		$this->log('Marking pipeline step as failed. See earlier log messages to determine cause.');
		$this->write();
		$this->Pipeline()->markFailed($notify);
	}
1109500
public function flush(string $errorMessage): void
    {
        if (! $this->hasErrors()) {
            return;
        }

        $exception = $this->resolveException($errorMessage, $this);

        $this->clearErrors();

        throw $exception;
    }
1011445
public static function printMessages($clearQueue = true)
    {
        if (!empty($_SESSION[__TRAIT__])) {
            /** @var Message $message */
            foreach ($_SESSION[__TRAIT__] as $message) {
                $message->output();
            }
        }

        if ($clearQueue) {
            static::clearQueue();
        }
    }
918231
public function sendVenueReply(bool $quoteOriginal = false): SendVenue
	{
		$m = $this->bot->sendVenue();
		$this->setReplyMarkup($m, $quoteOriginal);
		return $m;
	}
21063
public function error($nextUrl, $detail = null)
    {
        // If the signature is invalid, then do not allow the reject.

        if (! $this->isValid()) {
            throw new InvalidResponseException('Cannot reject an invalid notification');
        }

        $this->sendResponse(static::RESPONSE_STATUS_ERROR, $nextUrl, $detail);
    }
469252
public function sendContactReply(bool $quoteOriginal = false): SendContact
	{
		$m = $this->bot->sendContact();
		$this->setReplyMarkup($m, $quoteOriginal);
		return $m;
	}
451611
public function nack(Message $message, $multiple = false, $requeue = true)
    {
        return $this->nackImpl($message->deliveryTag, $multiple, $requeue);
    }
746039
public function recover($requeue = true)
    {
        $outputFrame = Basic\BasicRecoverFrame::create($requeue);
        $outputFrame->frameChannelId = $this->id;
        $this->connection->command($outputFrame);
    }
1343280
public function onFatalError($callback, $clearOutput = false)
    {
        if (!$clearOutput) {
            $this->onFatalError = $callback;
        } else {
            $this->onFatalError = function ($error) use ($callback) {
                $this->clearOutputBuffer();
                $callback($error);
            };
        }
    }
393511
function notice( $string = false, $addEOL = true )
    {
        fputs( STDERR, $string );
        if ( $addEOL )
            fputs( STDERR, $this->endlineString() );
    }