| Mvalve documentation | view source | Contained in the Mvalve distribution. |
Mvalve::Reader - Mvalve Reader
Fetches the next available message.
Checks whethere there are pending retries for that particular destination.
throttler holds the Data::Throttler instance that does the dirty work of
determining if a message needs to be throttled or not
$self->throttler( {
module => "Data::Throttler::Memcached",
} );
timeout specifies the timeout value while we wait to read from the queue.
drop_on_emergency specifies if given a emergency message, other messages
should be dropped while the emergency message is being displayed.
By default this is true.
| Mvalve documentation | view source | Contained in the Mvalve distribution. |