py-rodo 0.0.1

Usage

The main entry point for this library is the QueueProcessor class, which listens to the message bus, processes messages and invokes user defined callbacks depending on the message routing keys.

The message callback functions receive a child class of ObsMessageBusPayloadBase as the single argument and should return nothing. The specific subtype of ObsMessageBusPayloadBase can be infered from the dictionary QUEUE_TO_PAYLOAD_TYPE which maps the routing keys to specific payload types.

To only process package commit messages, create the following callback:

def commit_to_my_package(payload: PackageCommitPayload) -> None:
    # process the payload here

callbacks = {RoutingKey.PACKAGE_COMMIT: commit_to_my_package}

qp = QueueProcessor(callbacks=callbacks)
qp.listen_forever()