Metadata-Version: 2.4
Name: dirigent-block-queues
Version: 0.17.3
Summary: The queue block family for dirigent: Kafka and RabbitMQ, with their connection kinds.
License-Expression: LicenseRef-Proprietary
License-File: LICENSE
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.13
Requires-Dist: aio-pika>=9.5.7
Requires-Dist: aiokafka>=0.12.0
Requires-Dist: dirigent-common==0.17.3
Requires-Dist: dirigent-plugin==0.17.3
Requires-Python: >=3.13
Description-Content-Type: text/markdown

# dirigent-block-queues

The queue block family: `kafka.produce` and `rabbitmq.publish` send one message, and the
`kafka.consume` and `rabbitmq.consume` sensors wait for messages to arrive.

Each broker registers a connection kind of its own -- `kafka` and `rabbitmq` -- holding the
addresses, the credential and the TLS settings, so a step names a connection and a topic or a
queue. A consuming sensor parks the attempt until enough has arrived, and the place it has
read to is the sensor's cursor: a poke that parks commits nothing, so a batch too small to act
on is read again rather than lost.
