You can register several error handlers which will be called when an exception in the consuming process is thrown.
Every error handler must implement the interface
interface only requires one method
An error handler can be registered in the following way:
$manager = new Rebuy\Amqp\Consumer\ConsumerManager(...); $manager->registerErrorHandler(new MyErrorHandler());
As soon as one error handler is registered, the consuming of the message is considered successful. If you want to stop the consuming process, you must throw the passed exception (or an own exception) by yourself.
Implemented error handlers¶
Currently there are two error handlers implemented in this library:
- RequeuerHandler: Requeues the message so it can be processed at a later time
- LoggerHandler: Uses a LoggerInterface to log a warning message (this handler is only useful in combination with the RequeuerHandler)