Skip to content

messagequeue: Extract listen_messages from consume_messages

Give a way for developers to iter their development queues. For example, following messaging docs, a dev can open an ipython shell and do:

from cki_lib import messagequeue
queue = messagequeue.MessageQueue()
listener = queue.listen_messages(
    exchange="cki.exchange.webhooks",
    routing_keys=["gitlab.com.cki-project.#.issue"],
)
message = next(listener)
print(message.body)

To experiment with one message at a time with no need of a callback function.

Relates to: infrastructure#854

See also: documentation!583

Signed-off-by: Tales da Aparecida tales.aparecida@redhat.com

Edited by Tales da Aparecida

Merge request reports

Loading