event-band/symfony-bundle

Symfony Bundle for EventBand

EventBandSymfonyBundle

Symfony2 Bundle for EventBand framework , _(*1)

Quick start

Adding event-band to a symfony2 project

Run the following commands: ``` bash $ composer require "event-band/symfony-bundle:~1.0" $ composer require "event-band/amqplib-transport:~1.0", _(*2)

## Simple configuration
### Creating an event
Create an event, extending the EventBand\Adapter\Symfony\SerializableSymfonyEvent
``` php
<?php
namespace Acme\EventBundle\Event;
use EventBand\Adapter\Symfony\SerializableSymfonyEvent;

class EchoEvent extends SerializableSymfonyEvent
{
    /**
     * @var string
     **/
    protected $message;

    public function __construct($message)
    {
        $this->message = $message;
    }

    public funciton getMessage()
    {
        return $this->message;
    }

    protected function toSerializableArray()
    {
        $array = parent::toSerializableArray();
        $array['message'] = $this->message;

        return $array;
    }

    protected function fromUnserializedArray(array $data)
    {
        parent::fromUnserializedArray($data);
        $this->message = $data['message'];
    }
}

Creating a listener

Then create a listener, _(*3)

<?php
namespace Acme\EventBundle\Event;

class EchoEventListener
{
    public function onEchoEvent(EchoEvent $event)
    {
        // don't do such things on production
        echo $event->getMessage();
        echo "\n";
    }
}

And register listener in services.xml, _(*4)

<service id="acme.event_bundle.event.event_listener" class="Acme\EventBundle\EchoEventListener">
     <tag name="kernel.event_listener" event="event.echo" method="onEchoEvent"/>
</service>

Configuring bands

Add the following lines to your config.yml, _(*5)

event_band:
     publishers:
         acme.echo.event.publisher:
             events: ["event.echo"]
             transport:
                 amqp:
                     exchange: acme.echo.event.exchange
     consumers:
         acme.echo.event: ~

Adding band information to listener to make it asynchronous

Add parameter band with name of consumer to event listener tag to show which consumer it belongs to., _(*6)

<service id="acme.event_bundle.event.event_listener" class="Acme\EventBundle\EchoEventListener">
     <tag name="kernel.event_listener" event="event.echo" method="onEchoEvent" band="acme.echo.event"/>
</service>

Creating AMQP config

This step is not required, but it's very useful to have this config. Under the event_band space add the following lines to your config.yml, _(*7)

    transports:
         amqp:
             driver: amqplib
             connections:
                 default:
                     exchanges:
                         acme.echo.event.exchange: ~
                     queues:
                         acme.echo.event:
                             bind:
                                 acme.echo.event.exchange: ['event.echo']

Now you can call app/console event-band:setup amqp:default command and all the exchanges, queues and bindings will be automatically created/altered., _(*8)

Using asynchronous event

Somewhere in your code use event dispatcher to dispatch the EchoEvent as you usually do., _(*9)

$dispatcher = $this->getContainer()->get('event_dispatcher');
$dispatcher->dispatch('event.echo', new EchoEvent('Hi, guys!'));

When you run this code, event will be pushed to the acme.echo.event queue. Now run console command event-band:dispatch with the name of your consumer - acme.echo.event., _(*10)

sh$ app/cosole event-band:dispatch acme.echo.event
Hi, guys!

... Profit., _(*11)

Using JMSSerializer

Adding dependencies

Run composer require "event-band/jms-serializer:~1.0" command, _(*12)

Creating an event

``` php <?php namespace Acme\EventBundle\Event;, <sub>(*13)</sub>

class EchoEvent implements \EventBand\Event { /** * @var array * @JMS\Serializer\Annotation\Type("array") */ private $data;, <sub>(*14)</sub>

public function __construct($message)
{
    $this->date['message'] = $message;
}

public function getMessage()
{
    return $this->data['message'];
}

}, <sub>(*15)</sub>

### Config
Add the following lines under 'event_band' section in your config.yml
```yml
serializers:
        serializer:
            jms:
                format: json

All the other settings are similar., <sub>(*16)</sub>