evaneos / hector-bundle
AMQP wrapper of php C extension in order to easily manipulate connection, channel, queue and exchange
Installs: 154
Dependents: 0
Suggesters: 0
Security: 0
Stars: 0
Watchers: 14
Forks: 0
Type:symfony-bundle
Requires
- php: >=5.5
- evaneos/hector: ^1.0
- symfony/framework-bundle: ~2.3|3.0
Requires (Dev)
- beberlei/assert: ^2.4
- fabpot/php-cs-fixer: ^1.10
- phpspec/phpspec: ^2.3
- symfony/var-dumper: ^3.0
Suggests
- symfony/event-dispatcher: Hector dispatch some event that you can listen
This package is auto-updated.
Last update: 2020-10-17 22:16:23 UTC
README
Symfony Bundle for Hector
Installation
composer require evaneos\hector-bundle
public function registerBundles() { $bundles = array( ... new Evaneos\HectorBundle\HectorBundle() ); }
Configuration
hector: connections: default: host: %amqp.host% port: %amqp.port% login: %amqp.login% password: %amqp.password% vhost: %amqp.vhost% read_timeout: %amqp.read_timeout% write_timeout: %amqp.write_timeout% connect_timeout: %amqp.connect_timeout% exchanges: bill: flags: 2 #durable type: "topic" queues: bill.process: flags: 2 #durable routing_key: "process" bill.process_dropped: flags: 2 #durable routing_key: "bill.dropped" bill.logger: flags: 2 #durable routing_key: "event_bus.bill.*" bill.delayed: flags: 2 #durable type: "topic" queues: bill.process_retry_5: flags: 2 #durable routing_key: "process.retry.5" arguments: x-message-ttl: 300000 x-dead-letter-exchange: "bill.delayed" x-dead-letter-routing-key: "process.retry.10" bill.process_retry_10: flags: 2 #durable routing_key: "process.retry.10" arguments: x-message-ttl: 600000 x-dead-letter-exchange: "bill.delayed" x-dead-letter-routing-key: "process.retry.30" bill.process_retry_30: flags: 2 #durable routing_key: "process.retry.30" arguments: x-message-ttl: 1800000 x-dead-letter-exchange: "bill.delayed" x-dead-letter-routing-key: "process.retry.60" bill.process_retry_60: flags: 2 #durable routing_key: "process.retry.60" arguments: x-message-ttl: 3600000 x-dead-letter-exchange: "bill.delayed" x-dead-letter-routing-key: "process.retry.60" bill.process_retry_360: flags: 2 #durable routing_key: "process.retry.360" arguments: x-message-ttl: 21600000 x-dead-letter-exchange: "bill" x-dead-letter-routing-key: "process.dropped"
Publisher
services: evaneos.bill.publisher: class: 'Evaneos\Hector\Publisher\Publisher' tags: - { name: "hector.publisher", exchange: "bill" } evaneos.bill_delayed.publisher: class: 'Evaneos\Hector\Publisher\Publisher' tags: - { name: "hector.publisher", exchange: "bill.delayed", routing_key_prefix: "bill.retry." }
$publisher = $container->get('evaneos.bill.publisher'); $publisher->publish(json_encode(['bill']), 'process');
Consumer
services: evaneos.bill.consumer: class: 'Evaneos\Hector\Consumer\Consumer' tags: - { name: "hector.consumer", exchange: "bill", queue: "bill.process" } evaneos.webhook.consumer: class: 'Evaneos\Hector\Consumer\Consumer' tags: - { name: "hector.consumer", exchange: "bill", queue: "bill.logger" }
$consumer = $container->get('evaneos.bill.consumer'); $consumer->initialize(); /* @var AMQPQueue $queue */ $queue = $this->consumer->getQueue()->getWrappedQueue(); //$queue->get(); //$queue->consume(function(AMQPEnveloppe $message){}); // $this->reactConsumer = new Consumer($queue, $this->loop, 0.1, 10);
Utils
Run test
composer test
Run CS fixer
composer cs