Package qpid :: Package messaging :: Module driver
[frames] | no frames]

Module driver

source code

Classes
  Attachment
  Pattern
The pattern filter matches the supplied wildcard pattern against a message subject.
  SessionState
  LinkIn
  LinkOut
  Cache
  Driver
  Engine
Functions
 
addr2reply_to(addr) source code
 
reply_to2addr(reply_to) source code
 
noop() source code
 
sync_noop() source code
 
get_bindings(opts, queue=None, exchange=None, key=None) source code
Variables
  log = getLogger("qpid.messaging")
  rawlog = getLogger("qpid.messaging.io.raw")
  opslog = getLogger("qpid.messaging.io.ops")
  DURABLE_DEFAULT = False
  SUBJECT_DEFAULTS = {'topic': '#'}
  POLICIES = Values("always", "sender", "receiver", "never")
  RELIABILITY = Values("unreliable", "at-most-once", "at-least-o...
  DECLARE = Map({}, restricted= False)
  BINDINGS = List(Map({"exchange": Types(basestring), "queue": T...
  COMMON_OPTS = {"create": POLICIES, "delete": POLICIES, "assert...
  RECEIVE_MODES = Values("browse", "consume")
  SOURCE_OPTS = COMMON_OPTS.copy()
  TARGET_OPTS = COMMON_OPTS.copy()
  HEADER = '!4s4B'
  EMPTY_DP = DeliveryProperties()
  EMPTY_MP = MessageProperties()
  SUBJECT = 'qpid.subject'
  CLOSED = 'CLOSED'
  READ_ONLY = 'READ_ONLY'
  WRITE_ONLY = 'WRITE_ONLY'
  OPEN = 'OPEN'
  DEFAULT_DISPOSITION = Disposition(None)
  CONNECTION_ERRS = {}
  SESSION_ERRS = {403: <class 'qpid.messaging.exceptions.Unautho...
  __package__ = 'qpid.messaging'
  bases = (<class 'qpid.ops.Primitive'>)
  name = 'Bit'
Variables Details

RELIABILITY

Value:
Values("unreliable", "at-most-once", "at-least-once", "exactly-once")

BINDINGS

Value:
List(Map({"exchange": Types(basestring), "queue": Types(basestring), "\
key": Types(basestring), "arguments": Map({}, restricted= False)}))

COMMON_OPTS

Value:
{"create": POLICIES, "delete": POLICIES, "assert": POLICIES, "node": M\
ap({"type": Values("queue", "topic"), "durable": Types(bool), "x-decla\
re": DECLARE, "x-bindings": BINDINGS}), "link": Map({"name": Types(bas\
estring), "durable": Types(bool), "reliability": RELIABILITY, "x-decla\
re": DECLARE, "x-bindings": BINDINGS, "x-subscribe": Map({}, restricte\
d= False)})}

SESSION_ERRS

Value:
{403: <class 'qpid.messaging.exceptions.UnauthorizedAccess'>,
 404: <class 'qpid.messaging.exceptions.NotFound'>,
 405: <class 'qpid.messaging.exceptions.ReceiverError'>,
 506: <class 'qpid.messaging.exceptions.TargetCapacityExceeded'>,
 541: <class 'qpid.messaging.exceptions.ServerError'>}