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

Module async

source code

Provides async AMQP message consumer classes.

Classes [hide private]
  ReplyConsumer
A request, reply consumer.
  AsyncReply
Asynchronous request reply.
  FinalReply
A (final) reply.
  Succeeded
Successful reply to asynchronous operation.
  Failed
Failed reply to asynchronous operation.
  Started
An asynchronous operation started.
  Progress
Progress reported for an asynchronous operation.
  Listener
An asynchronous operation callback listener.
  WatchDog
A watchdog object used to track asynchronous messages by serial number.
  WatchDogThread
Watchdog thread.
  Journal
Async message journal
  LazyDog
A lazy (good-for-nothing) watchdog.
Variables [hide private]
  log = getLogger(__name__)
  __package__ = 'gofer.rmi'