Return information about queues from which worker consumes tasks. Returns: Dict: Dictionary ``{HOSTNAME: [QUEUE_INFO, QUEUE_INFO,...]}``. Here is the list of ``QUEUE_INFO`` fields: * ``name`` * ``exchange`` * ``name`` * ``type``
(self)
| 294 | return self._request('ping') |
| 295 | |
| 296 | def active_queues(self): |
| 297 | """Return information about queues from which worker consumes tasks. |
| 298 | |
| 299 | Returns: |
| 300 | Dict: Dictionary ``{HOSTNAME: [QUEUE_INFO, QUEUE_INFO,...]}``. |
| 301 | |
| 302 | Here is the list of ``QUEUE_INFO`` fields: |
| 303 | |
| 304 | * ``name`` |
| 305 | * ``exchange`` |
| 306 | * ``name`` |
| 307 | * ``type`` |
| 308 | * ``arguments`` |
| 309 | * ``durable`` |
| 310 | * ``passive`` |
| 311 | * ``auto_delete`` |
| 312 | * ``delivery_mode`` |
| 313 | * ``no_declare`` |
| 314 | * ``routing_key`` |
| 315 | * ``queue_arguments`` |
| 316 | * ``binding_arguments`` |
| 317 | * ``consumer_arguments`` |
| 318 | * ``durable`` |
| 319 | * ``exclusive`` |
| 320 | * ``auto_delete`` |
| 321 | * ``no_ack`` |
| 322 | * ``alias`` |
| 323 | * ``bindings`` |
| 324 | * ``no_declare`` |
| 325 | * ``expires`` |
| 326 | * ``message_ttl`` |
| 327 | * ``max_length`` |
| 328 | * ``max_length_bytes`` |
| 329 | * ``max_priority`` |
| 330 | |
| 331 | See Also: |
| 332 | See the RabbitMQ/AMQP documentation for more details about |
| 333 | ``queue_info`` fields. |
| 334 | Note: |
| 335 | The ``queue_info`` fields are RabbitMQ/AMQP oriented. |
| 336 | Not all fields applies for other transports. |
| 337 | """ |
| 338 | return self._request('active_queues') |
| 339 | |
| 340 | def query_task(self, *ids): |
| 341 | """Return detail of tasks currently executed by workers. |