| /dports/net-mgmt/librenms/librenms-vendor-21.5.1/php-amqplib/php-amqplib/PhpAmqpLib/Helper/Protocol/ |
| H A D | Protocol080.php | 553 $consumer_tag = '',
583 public function basicCancel($consumer_tag, $nowait = false)
645 … public function basicDeliver($consumer_tag, $delivery_tag, $redelivered, $exchange, $routing_key)
793 $consumer_tag = '',
823 public function fileCancel($consumer_tag, $nowait = false)
929 $consumer_tag,
1011 $consumer_tag = '',
1040 public function streamCancel($consumer_tag, $nowait = false)
1106 public function streamDeliver($consumer_tag, $delivery_tag, $exchange, $queue)
|
| H A D | Protocol091.php | 622 $consumer_tag = '',
654 public function basicCancel($consumer_tag, $nowait = false)
721 … public function basicDeliver($consumer_tag, $delivery_tag, $redelivered, $exchange, $routing_key)
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_stream/src/ |
| H A D | rabbit_stream_metrics.erl | 65 consumer_tag(SubscriptionId) -> function
|
| /dports/net/py-amqp/amqp-2.6.1/amqp/ |
| H A D | channel.py | 1397 def basic_cancel(self, consumer_tag, nowait=False, argsig='sb'): argument
1443 def _on_basic_cancel(self, consumer_tag): argument
1455 def _on_basic_cancel_ok(self, consumer_tag): argument
1458 def _remove_tag(self, consumer_tag): argument
1462 def basic_consume(self, queue='', consumer_tag='', no_local=False, argument
1595 def _on_basic_deliver(self, consumer_tag, delivery_tag, redelivered, argument
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/ |
| H A D | rabbit_fifo_v0.hrl | 42 -type consumer_tag() :: binary(). type
|
| H A D | rabbit_fifo.hrl | 42 -type consumer_tag() :: binary(). type
|
| H A D | rabbit_queue_consumers.erl | 459 consumer_tag(#consumer{tag = CTag}) -> function
|
| /dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/ |
| H A D | channel.py | 239 def _cancel_consumer(self, obj, consumer_tag=None, nowait=False): argument
249 def _on_ready_to_cancel(self, consumer_tag, nowait): argument
|
| H A D | amqp.py | 40 def basic_consume(self, queue='', consumer_tag='', no_local=False, argument
90 def basic_cancel(self, consumer_tag='', nowait=False): argument
|
| /dports/net/p5-Net-RabbitMQ/Net--RabbitMQ-0.2.8/ |
| H A D | amqp_framing.h | 308 amqp_bytes_t consumer_tag; member
317 amqp_bytes_t consumer_tag; member
322 amqp_bytes_t consumer_tag; member
328 amqp_bytes_t consumer_tag; member
351 amqp_bytes_t consumer_tag; member
412 amqp_bytes_t consumer_tag; member
421 amqp_bytes_t consumer_tag; member
426 amqp_bytes_t consumer_tag; member
432 amqp_bytes_t consumer_tag; member
471 amqp_bytes_t consumer_tag; member
[all …]
|
| H A D | RabbitMQ.xs | 483 char *consumer_tag = NULL; variable
|
| /dports/devel/py-pika/pika-1.1.0/pika/adapters/ |
| H A D | blocking_connection.py | 1062 consumer_tag, argument
1119 def __init__(self, params, consumer_tag): argument
1589 consumer_tag=None, argument
1640 consumer_tag, argument
1714 def basic_cancel(self, consumer_tag): argument
1812 def _remove_pending_deliveries(self, consumer_tag): argument
1868 def stop_consuming(self, consumer_tag=None): argument
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_federation/src/ |
| H A D | rabbit_federation_queue_link.erl | 310 consumer_tag(#upstream{consumer_tag = ConsumerTag}) -> function
|
| /dports/net/rabbiteer/rabbiteer-rs-c881238/src/ |
| H A D | output.rs | 9 consumer_tag: String, field
|
| H A D | client.rs | 259 let consumer_tag = "".to_string(); in do_open_receive() localVariable
|
| /dports/net/pecl-amqp/amqp-1.10.2/stubs/ |
| H A D | AMQPQueue.php | 62 public function cancel($consumer_tag = '')
|
| /dports/databases/py-carbon/carbon-1.1.8/lib/carbon/ |
| H A D | amqp_listener.py | 99 consumer_tag = "graphite_consumer" variable in AMQPGraphiteProtocol
|
| /dports/net/py-kombu/kombu-4.6.11/kombu/transport/ |
| H A D | SLMQ.py | 53 def basic_cancel(self, consumer_tag): argument
|
| /dports/devel/py-pika/pika-1.1.0/pika/ |
| H A D | channel.py | 204 def basic_cancel(self, consumer_tag='', callback=None): argument
267 consumer_tag=None, argument
969 def _cleanup_consumer_ref(self, consumer_tag): argument
|
| /dports/net/py-kombu/kombu-4.6.11/kombu/ |
| H A D | messaging.py | 592 def _basic_consume(self, queue, consumer_tag=None, argument
601 def _add_tag(self, queue, consumer_tag=None): argument
|
| H A D | entity.py | 715 def consume(self, consumer_tag='', callback=None, argument
745 def cancel(self, consumer_tag): argument
|
| /dports/net/pecl-amqp/amqp-1.10.2/ |
| H A D | amqp_queue.c | 517 char *consumer_tag = NULL; PHP5to7_param_str_len_type_t consumer_tag_len = 0; in PHP_METHOD() local
942 char *consumer_tag = NULL; PHP5to7_param_str_len_type_t consumer_tag_len = 0; in PHP_METHOD() local
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_stomp/src/ |
| H A D | rabbit_stomp_util.erl | 34 consumer_tag(Frame) -> function
|
| /dports/net/py-amqplib/amqplib-1.0.2/amqplib/client_0_8/ |
| H A D | channel.py | 1745 def basic_cancel(self, consumer_tag, nowait=False): argument
1821 def basic_consume(self, queue='', consumer_tag='', no_local=False, argument
|
| /dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/rabbitmq-include/ |
| H A D | amqp_framing.h | 580 amqp_bytes_t consumer_tag; /**< consumer-tag */ member
593 amqp_bytes_t consumer_tag; /**< consumer-tag */ member
601 amqp_bytes_t consumer_tag; /**< consumer-tag */ member
610 amqp_bytes_t consumer_tag; /**< consumer-tag */ member
641 amqp_bytes_t consumer_tag; /**< consumer-tag */ member
|