Acknowledges one or more messages

@param string $delivery_tag
@param bool $multiple
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);
    }
163228
public function messageHandler(PhpAmqpLib\Message\AMQPMessage $message)
    {
        echo "\n--------\n";
        echo $message->body;
        echo "\n--------\n";

        $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
        if ($message->body === 'quit') {
            $message->delivery_info['channel']->basic_cancel($message->delivery_info['consumer_tag']);
        }
    }
1157601
public function add_tag($tag, $message = null) {
		if ($message === null) {
			$message = $tag;
		}
		return $this->run("tag -a $tag -m " . escapeshellarg($message));
	}
1025330
void notifyOmemoMucMessageReceived(MultiUserChat muc,
                                       Stanza stanza,
                                       OmemoMessage.Received decryptedMessage) {
        for (OmemoMucMessageListener l : omemoMucMessageListeners) {
            l.onOmemoMucMessageReceived(muc, stanza, decryptedMessage);
        }
    }
750268
def _recv_ack(self, method_frame):
        ''''''
        if self._ack_listener:
            delivery_tag = method_frame.args.read_longlong()
            multiple = method_frame.args.read_bit()
            if multiple:
                while self._last_ack_id < delivery_tag:
                    self._last_ack_id += 1
                    self._ack_listener(self._last_ack_id)
            else:
                self._last_ack_id = delivery_tag
                self._ack_listener(self._last_ack_id)
569091
public function nack($deliveryTag = 0, $multiple = false, $requeue = true)
    {
        return $this->getClient()->nack($this->getChannelId(), $deliveryTag, $multiple, $requeue);
    }
1058858
public function basic_reject($delivery_tag, $requeue)
    {
        list($class_id, $method_id, $args) = $this->protocolWriter->basicReject($delivery_tag, $requeue);
        $this->send_method_frame(array($class_id, $method_id), $args);
    }
282640
public void sendMessage(String requestMessage, String queueName, String correlationId,
            final Queue replyQueue, int delaySeconds, int deliveryMode) throws JMSException {
        /**
         * If it's an internal message then always use jmsTemplate for ActiveMQ
         */

        if (jmsTemplate != null) {
            jmsTemplate.setDeliveryMode(deliveryMode);
            if (!StringUtils.isEmpty(queueName)) {
                jmsTemplate.send(queueName, new MDWMessageCreator(requestMessage, correlationId,
                        replyQueue, delaySeconds));

            }
            else {
                jmsTemplate.send(new MDWMessageCreator(requestMessage, correlationId, replyQueue));
            }
        }
    }
98689
def nack(self, delivery_tag, multiple=False, requeue=False):
        ''''''
        args = Writer()
        args.write_longlong(delivery_tag).\
            write_bits(multiple, requeue)

        self.send_frame(MethodFrame(self.channel_id, 60, 120, args))
3675
def pending_confirmations(self):
        
        return sorted([(idx, msg)
                       for idx, msg in enumerate(self.published_messages)
                       if not msg.future.done()],
                      key=lambda x: x[1].delivery_tag)
283685
public function basicAck($deliveryTag, $multiple)
    {
        $args = new Writer();
        $args->writeLongLong($deliveryTag)
            ->writeBit($multiple);
        return $args;
    }
49022
def requeue(self):
        
        if self.acknowledged:
            raise self.MessageStateError(
                "Message already acknowledged with state: %s" % self._state)
        self.backend.requeue(self.delivery_tag)
        self._state = "REQUEUED"
1218519
def reject_message(self, delivery_tag, requeue=False, **kwargs):
        
        logger.info('Rejecting message', delivery_tag=delivery_tag, **kwargs)
        self._channel.basic_reject(delivery_tag, requeue=requeue)
88353
public boolean supportDeliveryMode( int deliveryMode )
    {
    	switch (deliveryMode)
    	{
    		case DeliveryMode.PERSISTENT :     return initialBlockCount > 0;
    		case DeliveryMode.NON_PERSISTENT : return maxNonPersistentMessages > 0;
    		default :
    			throw new IllegalArgumentException("Invalid delivery mode : "+deliveryMode);
    	}
    }
45159
public function delivery($msg_id, $msg_key)
    {
        $data = [
            'message_id' => $msg_id,
            'message_key' => $msg_key
        ];

        $xml = static::renderXML('delivery', $data);

        $response = $this->sendRequest($xml);

        // disable warnings
        libxml_use_internal_errors(true);

        $xmlresp = simplexml_load_string($response);
        $arr = json_decode(json_encode($xmlresp), true);

        // re-enable warnings
        libxml_clear_errors();
        libxml_use_internal_errors(false);

        $delivery = new DhiraaguSmsDelivery($arr);

        if (empty($delivery->message_status_id)) {
            throw DhiraaguDeliveryException::messageFailed($delivery->response_status, $delivery->response_status_desc);
        }

        return $delivery;
    }
448457
public function acknowledge(AMQPMessage $message)
    {
        $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);

        if ($message->body === 'quit') {
            $message->delivery_info['channel']->basic_cancel($message->delivery_info['consumer_tag']);
        }
    }
708871
public function nack($deliveryTag, array $options = [])
    {
        $multiple = array_key_exists('multiple', $options) ? (int)$options['multiple'] : null;
        $requeue = array_key_exists('requeue', $options) ? (bool)$options['requeue'] : null;

        $outputFrame = Basic\BasicNackFrame::create($deliveryTag, $multiple, $requeue);
        $outputFrame->frameChannelId = $this->id;
        $this->connection->command($outputFrame);
    }