Package qpid :: Package messaging :: Module driver

[frames] | no frames]

Module driver

source code

Classes

[hide private]

Attachment

Pattern
The pattern filter matches the supplied wildcard pattern against a message subject.

SessionState

LinkIn

LinkOut

Cache

Driver

Engine

Functions

[hide private]

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

[hide private]

log = getLogger("qpid.messaging")

rawlog = getLogger("qpid.messaging.io.raw")

opslog = getLogger("qpid.messaging.io.ops")

DURABLE_DEFAULT = False

SUBJECT_DEFAULTS = {'topic': '#'}

ppid = 9459

CLIENT_PROPERTIES = {'platform': 'posix', 'product': 'qpid pyt...

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

[hide private]

CLIENT_PROPERTIES

Value:

{'platform': 'posix',
 'product': 'qpid python client',
 'qpid.client_pid': 9460,
 'qpid.client_ppid': 9459,
 'qpid.client_process': '(imported)',
 'version': 'development'}

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'>}