public function reject($delivery_tag, $flags = AMQP_NOPARAM) {

        $requeue = boolval($flags & AMQP_REQUEUE);

        try {
            $this->channel->_getChannel()->basic_reject($delivery_tag, $requeue);
        } catch (AMQPRuntimeException $e) {
            throw new AMQPConnectionException($e->getMessage(), $e->getCode(), $e->getPrevious());
        } catch (Exception $e) {
            return false;
        }

        return true;
    }
public function reject($delivery_tag, $flags = AMQP_NOPARAM) {

        $requeue = boolval($flags & AMQP_REQUEUE);

        try {
            $this->channel->_getChannel()->basic_reject($delivery_tag, $requeue);
        } catch (AMQPRuntimeException $e) {
            throw new AMQPConnectionException($e->getMessage(), $e->getCode(), $e->getPrevious());
        } catch (Exception $e) {
            return false;
        }

        return true;
    }
public function reject ( $ delivery_tag , $ flags = AMQP_NOPARAM ) { $ requeue = boolval ( $ flags & AMQP_REQUEUE ) ; try { $ this -> channel -> _getChannel ( ) -> basic_reject ( $ delivery_tag , $ requeue ) ; } catch ( AMQPRuntimeException $ e ) { throw new AMQPConnectionException ( $ e -> getMessage ( ) , $ e -> getCode ( ) , $ e -> getPrevious ( ) ) ; } catch ( Exception $ e ) { return false ; } return true ; }
Mark one message as explicitly not acknowledged.

Mark the message identified by delivery_tag as explicitly not
acknowledged. This method can only be called on messages that have not
yet been acknowledged, meaning that messages retrieved with by
AMQPQueue::consume() and AMQPQueue::get() and using the AMQP_AUTOACK
flag are not eligible.

@param string $delivery_tag Delivery tag of the message to reject.
@param integer $flags AMQP_REQUEUE to requeue the message(s).

@throws AMQPChannelException    If the channel is not open.
@throws AMQPConnectionException If the connection to the broker was lost.

@return boolean
Mark one message as explicitly not acknowledged .