Package gofer :: Package rmi :: Module store
[hide private]
[frames] | no frames]

Module store

source code

Provides (local) message storage classes.

Classes [hide private]
  PendingQueue
Persistent (local) storage of pending envelopes that have been processed of an AMQP queue.
  PendingThread
A pending queue receiver.
Variables [hide private]
  log = getLogger(__name__)
  __package__ = 'gofer.rmi'