Daisuke Maki > Mvalve-0.00014 > Mvalve::Reader

Download:
Mvalve-0.00014.tar.gz

Dependencies

Annotate this POD

CPAN RT

New  1
Open  0
View/Report Bugs
Source  

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.

syntax highlighting: