| /dports/net/py-kombu/kombu-4.6.11/kombu/ |
| H A D | simple.py | 26 def __init__(self, channel, producer, consumer, no_ack=False): argument
114 no_ack = False variable in SimpleQueue
119 def __init__(self, channel, name, no_ack=None, queue_opts=None, argument
149 no_ack = True variable in SimpleBuffer
|
| H A D | compat.py | 19 def _iterconsume(connection, consumer, no_ack=False, limit=None): argument
138 def fetch(self, no_ack=None, enable_callbacks=False): argument
156 def iterconsume(self, limit=None, no_ack=None): argument
193 def iterconsume(self, limit=None, no_ack=False): argument
|
| H A D | messaging.py | 309 no_ack = None variable in Consumer
367 def __init__(self, channel, queues=None, no_ack=None, auto_declare=None, argument
459 def consume(self, no_ack=None): argument
593 no_ack=no_ack, nowait=True): argument
|
| H A D | entity.py | 546 no_ack = False variable in Queue
682 def get(self, no_ack=None, accept=None): argument
716 no_ack=None, nowait=False): argument
|
| /dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/ |
| H A D | amqp_queue.py | 171 def consume(self, no_ack=False, prefetch=None, priority=None): argument
206 def consume_messages(self, no_ack=False, prefetch=None, priority=None): argument
230 def consumer(self, no_ack=False, prefetch=None, priority=None): argument
343 def _consume(self, no_ack=False, prefetch=None, priority=None): argument
|
| H A D | amqp.py | 41 no_ack=False, exclusive=False, nowait=False, argument
111 def basic_get(self, queue='', no_ack=False): argument
|
| H A D | simple.py | 49 def consume(uri=None, queue_name=None, no_ack=False, prefetch=None, argument
|
| /dports/net/rabbitmq-c-devel/rabbitmq-c-0.10.0/tools/ |
| H A D | consume.c | 142 int no_ack, int count, int prefetch_count, in do_consume()
205 static int no_ack = 0; in main() local
|
| /dports/net/rabbitmq-c/rabbitmq-c-0.11.0/tools/ |
| H A D | consume.c | 142 int no_ack, int count, int prefetch_count, in do_consume()
205 static int no_ack = 0; in main() local
|
| /dports/net/py-kombu/kombu-4.6.11/kombu/transport/ |
| H A D | azurestoragequeues.py | 45 no_ack = True variable in Channel
58 def basic_consume(self, queue, no_ack, *args, **kwargs): argument
|
| H A D | SLMQ.py | 47 def basic_consume(self, queue, no_ack, *args, **kwargs): argument
|
| /dports/sysutils/py-salt/salt-3004.1/salt/modules/ |
| H A D | celery.py | 46 no_ack=True, argument
|
| /dports/security/snort3/snort3-3.1.19.0/src/stream/tcp/ |
| H A D | tcp_stream_config.h | 73 bool no_ack; variable
|
| /dports/devel/py-celery/celery-4.4.7/celery/backends/ |
| H A D | amqp.py | 147 no_ack=True, on_interval=None, argument
225 def consume(self, task_id, timeout=None, no_ack=True, on_interval=None): argument
241 def get_many(self, task_ids, timeout=None, no_ack=True, argument
|
| H A D | rpc.py | 52 def start(self, initial_task_id, no_ack=True, **kwargs): argument
275 limit=1000, no_ack=False): argument
|
| /dports/games/openlierox/OpenLieroX/libs/coredumper/examples/ |
| H A D | tftpd.c | 89 int no_ack; member
453 int no_ack = 0; in main() local
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/extra/coredumper/examples/ |
| H A D | tftpd.c | 86 int no_ack; member
426 int no_ack = 0; in main() local
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/extra/coredumper/examples/ |
| H A D | tftpd.c | 86 int no_ack; member
426 int no_ack = 0; in main() local
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/extra/coredumper/examples/ |
| H A D | tftpd.c | 86 int no_ack; member
426 int no_ack = 0; in main() local
|
| /dports/net/hostapd-devel/hostap-14ab4a816/wlantest/ |
| H A D | rx_mgmt.c | 1922 size_t len, bool no_ack) in rx_mgmt_location_measurement_report()
1951 size_t len, bool no_ack) in rx_mgmt_action_no_bss_public()
1963 size_t len, bool no_ack) in rx_mgmt_prot_ftm_request()
1977 size_t len, bool no_ack) in rx_mgmt_prot_ftm()
1991 size_t len, bool no_ack) in rx_mgmt_prot_ftm_report()
2006 size_t len, bool no_ack) in rx_mgmt_action_no_bss_protected_ftm()
2024 bool no_ack) in rx_mgmt_action_no_bss()
2038 int valid, bool no_ack) in rx_mgmt_action()
|
| /dports/security/wpa_supplicant-devel/hostap-14ab4a816/wlantest/ |
| H A D | rx_mgmt.c | 1922 size_t len, bool no_ack) in rx_mgmt_location_measurement_report()
1951 size_t len, bool no_ack) in rx_mgmt_action_no_bss_public()
1963 size_t len, bool no_ack) in rx_mgmt_prot_ftm_request()
1977 size_t len, bool no_ack) in rx_mgmt_prot_ftm()
1991 size_t len, bool no_ack) in rx_mgmt_prot_ftm_report()
2006 size_t len, bool no_ack) in rx_mgmt_action_no_bss_protected_ftm()
2024 bool no_ack) in rx_mgmt_action_no_bss()
2038 int valid, bool no_ack) in rx_mgmt_action()
|
| /dports/net/p5-Net-RabbitMQ/Net--RabbitMQ-0.2.8/ |
| H A D | RabbitMQ.xs | 485 int no_ack = 1; variable
662 int no_ack = 1; variable
|
| H A D | amqp_api.c | 209 amqp_boolean_t no_ack, in amqp_basic_consume()
266 amqp_boolean_t no_ack) in amqp_basic_get()
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis/commands/ |
| H A D | streams.py | 136 count=None, latest_ids=None, no_ack=False): argument
260 no_ack=False): argument
|
| /dports/devel/py-celery/celery-4.4.7/celery/ |
| H A D | result.py | 171 no_ack=True, follow_parents=True, callback=None, on_message=None, argument
700 callback=None, no_ack=True, on_message=None, argument
716 callback=None, no_ack=True, on_message=None, argument
792 def iter_native(self, timeout=None, interval=0.5, no_ack=True, argument
811 interval=0.5, callback=None, no_ack=True, argument
|