florianajir/rabbitmq-sql-bundle

RabbitMQ to sql consumer, using doctrine/dbal and php-amqplib/rabbitmq-bundle

Rabbitmq-sql-worker

, _(*1)

, _(*2)

About

The RabbitMqSqlBundle is a symfony worker to provide rabbitmq message persistence for your application using the php-amqplib/rabbitmq-bundle and doctrine/dbal libraries., _(*3)

You just need to configure the mapping in yml and execute a command, a simple and scalable rabbitmq to sql consumer to persist your entities:, _(*4)

php app/console rabbitmq:consumer -w sql

Features

• mapping yml config (doctrine like)
• Insert records
• Update records
• Relational records : oneToOne, oneToMany, manyToOne, manyToMany
• Update, Delete relations
• Foreign keys support

Examples

Following example shows you the consuming process to persist in database a simple subscriber from an asynchronous message data., _(*5)

RabbitMQ incoming message data:, _(*6)

{
  "name" : "Rogger Rabbit",
  "email" : "subscriber@acme.corp",
  "Groups": [ { "slug": "subscriber" } ]
}

SQL requests output:, _(*7)

INSERT INTO `members` (`name`, `email`) VALUES ("Rogger Rabbit", "subscriber@acme.corp");
INSERT INTO `member_group` (`member_id`, `group_id`) VALUES (3, 2);

Take more inspiration from Examples documentation, _(*8)

License

This application is under the MIT license. See the complete license in this file :, _(*9)

Resources/meta/LICENSE

Installation

For Symfony Framework >= 2.3

Require the worker and its dependencies with composer:, _(*10)

$ composer require florianajir/rabbitmq-sql-worker

Register this bundles:, _(*11)

// app/AppKernel.php

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

Configuration

You have to configure the rabbitmq and the database and define message structures and database mapping., _(*12)

• Rabbitmq-sql Configuration
• Mapping Documentation

Enjoy !, _(*13)