NAME

Mvalve::Reader - Mvalve Reader

METHODS

next

Fetches the next available message.

defer

Inserts in the the retry_wait queue.

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.

clear_all

Clears all known queues that are listed under the registered QueueSet

queue

queue is the actual queue instance that we'll be dealing with. While the architecture is such that you can replace the queue with your custom object, we currently only support Q4M

  $self->queue( {
    module => "Q4M",
    connect_info => [ 'dbi:mysql:...', ..., ... ]
 } );