MCPcopy
hub / github.com/pika/pika / basic_ack

Method basic_ack

pika/channel.py:232–251  ·  view source on GitHub ↗

Acknowledge one or more messages. When sent by the client, this method acknowledges one or more messages delivered via the Deliver or Get-Ok methods. When sent by server, this method acknowledges one or more messages published with the Publish method on a channel in c

(self, delivery_tag: int = 0, multiple: bool = False)

Source from the content-addressed store, hash-verified

230 self.callbacks.add(self.channel_number, '_on_return', callback, False)
231
232 def basic_ack(self, delivery_tag: int = 0, multiple: bool = False) -> None:
233 """Acknowledge one or more messages. When sent by the client, this
234 method acknowledges one or more messages delivered via the Deliver or
235 Get-Ok methods. When sent by server, this method acknowledges one or
236 more messages published with the Publish method on a channel in
237 confirm mode. The acknowledgement can be for a single message or a
238 set of messages up to and including a specific message.
239
240 :param integer delivery_tag: int/long The server-assigned delivery tag
241 :param bool multiple: If set to True, the delivery tag is treated as
242 "up to and including", so that multiple messages
243 can be acknowledged with a single method. If set
244 to False, the delivery tag refers to a single
245 message. If the multiple field is 1, and the
246 delivery tag is zero, this indicates
247 acknowledgement of all outstanding messages.
248
249 """
250 self._raise_if_not_open()
251 return self._send_method(spec.Basic.Ack(delivery_tag, multiple))
252
253 def basic_cancel(self,
254 consumer_tag: str = '',

Callers 15

on_messageMethod · 0.45
on_messageMethod · 0.45
on_getMethod · 0.45
testMethod · 0.45
testMethod · 0.45
testMethod · 0.45
testMethod · 0.45
on_consumeMethod · 0.45
on_consumeMethod · 0.45

Calls 2

_raise_if_not_openMethod · 0.95
_send_methodMethod · 0.95

Tested by 15

on_messageMethod · 0.36
on_messageMethod · 0.36
on_getMethod · 0.36
testMethod · 0.36
testMethod · 0.36
testMethod · 0.36
testMethod · 0.36
on_consumeMethod · 0.36
on_consumeMethod · 0.36