Symfony2 Bundle builded on top of RabbitMq that allows to process asynchronously messages
The AsyncTasksBundle allows to send asynchronous messages in your Symfony2 Application via RabbitMq (using the php-amqplib library).
The message publishing is so easy.
Trt\AsyncTasksBundle\Event\AsyncEvent
$event = new AsyncEvent(
'async_event_name',
array('date'=> (new \DateTime())->format('d-m-Y H:s')
)
);
$this->get('event_dispatcher')->dispatch($event->getName(), $event);
Now if you want consume the messages
Trt\AsyncTasksBundle\Listener\ListenerInterface
interface.{name: trt_async.listener.listen, event: async_event_name}
, the event key is the event name.$ app/console trt:async:run async_event_name
All the examples expect a running RabbitMQ server.
This instructions have been tested on a project created with the Symfony2 Standard 2.3.4
Add the AsyncTasksBundle to your composer.json and type composer install.
"require": {
"php": ">=5.3.3",
....
"trt/async-tasks-bundle": "dev-master",
...
},
Add the AsyncTasksBundle to your application's kernel:
public function registerBundles()
{
$bundles = array(
...
new Trt\AsyncTasksBundle\TrtAsyncTasksBundle(),
...
);
...
}
trt_async_tasks:
# This prefix allows the dispatcher to detect async event,
# if you want use another prefix put here
event:
prefix: async_
mq:
# The rabbitMq host / port
connection_params:
host: %mq_host%
port: %mq_port%
# Define the exchange name for rabbitmq
exchange:
exchange: 'exchange_symfony_events'
AsyncTasksBundle's event detection mechanism is based on naming convention, the event name will be the same of queue name. every event with name containing the async
string will be detected as AysncEvent.
The name prefix cold be overridden via config
trt_async_tasks:
event:
prefix: acme_async
Fork it and contribute to solve the issues :-)
See: resources/meta/LICENSE.md
The bundle structure and the documentation is partially based on the SonataNotificationBundle