ContinuousPipe Message

This library contains the basic classes used to be able to publish and consume messages in or between ContinuousPipe services.

Symfony Bundle usage

message:
simple_bus:
connection: defaultcommand:
connection: defaultmessage_deadline_expiration_manager: continuouspipe.message.default.message_pullerconnections:
default:
driver: 'gps://google_project_id:base64_encoded_servie_account@subscription_name/topic_name'debug: truetideways:
api_key: %tideways_api_key%

SimpleBus

If you are working with SimpleBus and the AsynchronousBundle, you can do this:

worker:
service: simple_bus.rabbit_mq_bundle_bridge.commands_consumersimple_bus_asynchronous:
commands:
logging: ~publisher_service_id: continuouspipe.message.simple_bus.producer