NAME

Mvalve::Reader - Mvalve Reader

METHODS

next

Fetches the next available message.

is_pending( $destination )

Checks whethere there are pending retries for that particular destination.

throttler

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

timeout specifies the timeout value while we wait to read from the queue.

drop_on_emergency

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.