public function sendAck($payload)
    {

        if (empty($payload->delivery_info['delivery_tag'])) {
            throw new Exception('sendAck: delivery_tag not set.');
        }

        $payload->delivery_info['channel']->basic_ack($payload->delivery_info['delivery_tag']);
    }
public function sendAck($payload)
    {

        if (empty($payload->delivery_info['delivery_tag'])) {
            throw new Exception('sendAck: delivery_tag not set.');
        }

        $payload->delivery_info['channel']->basic_ack($payload->delivery_info['delivery_tag']);
    }
public function sendAck ( $ payload ) { if ( empty ( $ payload -> delivery_info [ 'delivery_tag' ] ) ) { throw new Exception ( 'sendAck: delivery_tag not set.' ) ; } $ payload -> delivery_info [ 'channel' ] -> basic_ack ( $ payload -> delivery_info [ 'delivery_tag' ] ) ; }
Sends an acknowledgement back to the message broker so the message can be
removed from the queue.

@param $payload
The payload received in the consume callback.
Sends an acknowledgement back to the message broker so the message can be removed from the queue .