Integration of the CommandBus library into Symfony2.
Require rezzza/command-bus-bundle
to your composer.json file:
{
"require": {
"rezzza/command-bus-bundle": "~2.0"
}
}Register the bundle in app/AppKernel.php:
// app/AppKernel.php
public function registerBundles()
{
return array(
// ...
new Rezzza\CommandBusBundle\RezzzaCommandBusBundle()
);
}Update your config.yml:
framework:
serializer:
enabled: true$bus = $container->get('rezzza_command_bus.command_bus.synchronous'); // synchronous is the name you given to your bus in configuration.
$bus->handle(new FooCommand());Direct, SncRedis & OldSoundRabbit are currently supported.
Commands must inherit from Rezzza\CommandBus\Domain\CommandInterface.
Register a command handler:
<service id="...." class="....">
<tag name="rezzza_command_bus.command_handler" command="FQCN\MyFirstActionCommand" /> <!-- when handle this command, method `myFirstAction` will be handled. -->
<tag name="rezzza_command_bus.command_handler" command="FQCN\MySecondActionCommand" method="myMethod" />
</service>Events:
- on_consumer_response
- pre_handle_command
Register a listener:
<service id="service_id" class="Foo">
<tag name="rezzza_command_bus.event_listener" event="pre_handle_command" method="onPreHandleCommand" />
<tag name="rezzza_command_bus.event_listener" event="on_consumer_response" method="onConsumerResponse" />
</service>
See command-bus documentation.
A Symfony console command is provided in this bundle
$ app/console rezzza:command_bus:consume "CommandToConsume"
Options available:
--consumer Which consumer should we use ? (default: "default")
--iteration-limit (-i) Limit of iterations, -1 for infinite.. (default: -1)
--time-limit During how many time this command will listen to the queue. (default: 60)
--usleep Micro seconds (default: 100000)
--lock Only one command processing ?
To watch activity of your consumer, you should register a console handler for monolog
monolog:
handlers:
console:
type: console
verbosity_levels:
VERBOSITY_NORMAL: NOTICErezzza_command_bus:
buses:
synchronous: direct
asynchronous:
rabbitmq:
#define producer_guesser which allow to determine rigth producer for each command
#producer name and command class name must be indentical
#example:
#producer name : source_entry_update
#command class name : SourceEntryUpdateCommand
producer_guesser: rezzza_command_bus.old_sound_rabbit.producer_guesser
consumer_bus: synchronous #consumer handle command with synchronous bus
snc_redis:
client: default # snc redis client.
read_block_timeout: 1 # see blpop documentation
consumers:
default:
bus: synchronous
fail_strategy:
retry_then_fail: # When the command fail, it uses this strategy.
# you could use too requeue, none, service.
attempts: 10
requeue_on_fail: true
handlers: # Do you want to use handlers provided in this bundle ?
retry: synchronous # If you used retry_then_fail strategy, this handler is linked to Retry commands.
failed: synchronous # If you used retry_then_fail strategy, this handler is linked to Failed commands.rezzza_command_bus:
logger_normalizer: symfony_serializer
services:
symfony_serializer:
class: "Symfony\Component\Serializer\Serializer"
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent