RabbitMqExample

Learn how to use RabbitMq with Symfony3

Symfony configuration:

Require the bundle in your composer.json file:

"require":  {
     "php-amqplib/php-amqplib": ">=2.6.1"
}

Register the bundle in app/AppKernel.php file:

public function registerBundles()
{
    $bundles = array(
        new OldSound\RabbitMqBundle\OldSoundRabbitMqBundle(),
    );
}

app/config/config.yml:

# OldSoundRabbitMq Configuration
old_sound_rabbit_mq:
    connections:
        default:
            host:     'localhost'
            port:     5672
            user:     'guest'
            password: 'guest'
            vhost:    '/'
            lazy:     false
    producers:
        api_call:
            connection:       default
            exchange_options: {name: 'api-call', type: direct}
            queue_options:    {name: 'api_call'}
    consumers:
        api_call:
            connection:       default
            exchange_options: {name: 'api_call', type: direct}
            queue_options:    {name: 'api_call'}
            callback:         example_consumer_service
            qos_options:      {prefetch_size: 0, prefetch_count: 1, global: false}

app/config/services.yml in services section:

    producer_service:
        class: AppBundle\Services\Producer
        arguments: ["@old_sound_rabbit_mq.api_call_producer"]
    # consumer example
    example_consumer_service:
        class:      AppBundle\Services\ExampleConsumer