NAME

Mvalve::Base - Base Class For Mvalve Reader/Writer

METHODS

defer

Inserts in the the retry_wait 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:...', ..., ... ]
} );