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: default

    command:
        connection: default
        message_deadline_expiration_manager: continuouspipe.message.default.message_puller

    connections:
        default:
            driver: 'gps://google_project_id:base64_encoded_servie_account@subscription_name/topic_name'
            debug: true
            
    tideways:
        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_consumer

simple_bus_asynchronous:
    commands:
        logging: ~
        publisher_service_id: continuouspipe.message.simple_bus.producer