gallna/amqp-event

Amqp message dispatcher

Sunday, August 7, 2016
by gall_na
Repository
1 Watchers
0 Stars
219 Installations

PHP
0 Dependents
0 Suggesters
0 Forks
0 Open issues
17 Versions
0 % Grown

The README.md

PHP module

https://github.com/pdezwart/php-amqp, _(*1)

Documentation

http://php.net/manual/pl/book.amqp.php, _(*2)

Examples

https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/php-amqp, _(*3)

Rabit implementation

https://github.com/php-amqplib/php-amqplib/tree/master/demo, _(*4)

Dispatch


$envelope = new Amqp\Envelope();
$dispatcher = $amqp->getDispatcher();

// Publish message to queue
$dispatcher->dispatch("kernel.error", new Amqp\PublishEvent($envelope));
$dispatcher->dispatch("kernel.warning", new Amqp\PublishEvent($envelope));

// Publish message to exchange
$envelope->setExchangeName("exchangeName");

$dispatcher->dispatch("kernel.critical", new Amqp\PublishEvent($envelope));
$dispatcher->dispatch("kernel.notice", new Amqp\PublishEvent($envelope));
$dispatcher->dispatch("kernel.info", new Amqp\PublishEvent($envelope));
$dispatcher->dispatch("kernel.info", new Event());
$dispatcher->dispatch("kernel.message", new Event());

To ensure message delivery to queue/exchange - dispatch MandatoryEvent instead of Event, _(*5)

Exception handling

PHP SPL exceptions, _(*6)

Logic Exceptions

Logic Exceptions are for errors that occur at compile time. Since PHP has no compile time in the sense this is meant, it usually is interpreted as "errors occuring during development", (like when the developer forgot to pass a depedency or rooting key), _(*7)

LogicException are moved to dead-letter exchange because they represents error in the program logic. This kind of exception should lead directly to a fix in code and requeue messages, _(*8)

DomainException (a LogicException subset) is thew when naither of listeners consumed the event (either by acknowledging or rejecting message). This can't be fixed otherwise than removing not supported route or adding missing acknowledgement, _(*9)

Runtime Exceptions

Runtime Exceptions are for unforseen errors (usually stemming from User Input) when the code is run., _(*10)

Those exceptions may be triggered by temporary connection issues, rate limits etc. They are moved automatically to wait exchange to retry them later., _(*11)

Throwable

It's up to developer how to handle any other Throwable by wrapping Consumer into try-catch block., _(*12)

it might be moved to headers exchange - and retried after implementing fix
might be moved to dead-letter exchange by message broker
rejecting erroring messages with AMQP_REQUEUE flag creates stream of one and the same messages. Keep an eye on retry-count to avoid issues

The Versions

07/08 2016

dev-master

9999999-dev

Amqp message dispatcher

library amqp-event

Amqp message dispatcher

gallna/amqp-event

The README.md

PHP module

Documentation

Examples

Rabit implementation

Dispatch

Exception handling

Logic Exceptions

Runtime Exceptions

Throwable

The Versions

dev-master

The Requires

The Development Requires

by Tomasz Jonik

3.0.2

The Requires

The Development Requires

by Tomasz Jonik

3.0.1

The Requires

The Development Requires

by Tomasz Jonik

3.0.0

The Requires

by Tomasz Jonik

dev-feature/v3

The Requires

by Tomasz Jonik

2.1.0

The Requires

by Tomasz Jonik

1.0.3

The Requires

by Tomasz Jonik

2.0.2

The Requires

by Tomasz Jonik

2.0.1

The Requires

by Tomasz Jonik

v2.x-dev

The Requires

by Tomasz Jonik

2.0

The Requires

by Tomasz Jonik

1.0.2

The Requires

by Tomasz Jonik

1.0.1

The Requires

by Tomasz Jonik

v0.3

The Requires

by Tomasz Jonik

1.0

The Requires

by Tomasz Jonik

v0.2

The Requires

by Tomasz Jonik

v0.1

The Requires

by Tomasz Jonik