Index

A

Ack (class in blazingmq)

AckStatus (class in blazingmq)

B

BasicHealthMonitor (class in blazingmq) BINARY (blazingmq.PropertyType attribute) blazingmq module

blazingmq.testing module BOOL (blazingmq.PropertyType attribute) BrokerTimeoutError

C

CANCELED (blazingmq.AckStatus attribute) CHAR (blazingmq.PropertyType attribute) close_queue() (blazingmq.Session method) CompressionAlgorithmType (class in blazingmq) configure_queue() (blazingmq.Session method)

confirm() (blazingmq.MessageHandle method) (blazingmq.Session method) Connected (class in blazingmq.session_events) ConnectionLost (class in blazingmq.session_events) ConnectionTimeout (class in blazingmq.session_events)

D

data (blazingmq.Message attribute) DEFAULT_CONSUMER_PRIORITY (blazingmq.QueueOptions attribute) DEFAULT_MAX_UNCONFIRMED_BYTES (blazingmq.QueueOptions attribute)

DEFAULT_MAX_UNCONFIRMED_MESSAGES (blazingmq.QueueOptions attribute) DEFAULT_SUSPENDS_ON_BAD_HOST_HEALTH (blazingmq.QueueOptions attribute) Disconnected (class in blazingmq.session_events)

E

Error (class in blazingmq.session_events)

G

get_queue_options() (blazingmq.Session method)

guid (blazingmq.Ack attribute) (blazingmq.Message attribute)

H

HostHealth (in module blazingmq.testing)

HostHealthRestored (class in blazingmq.session_events) HostUnhealthy (class in blazingmq.session_events)

I

INT32 (blazingmq.PropertyType attribute) INT64 (blazingmq.PropertyType attribute)

InterfaceError (class in blazingmq.session_events) INVALID_ARGUMENT (blazingmq.AckStatus attribute)

L

LIMIT_BYTES (blazingmq.AckStatus attribute)

LIMIT_MESSAGES (blazingmq.AckStatus attribute) log_session_event() (in module blazingmq.session_events)

M

Message (class in blazingmq) MessageHandle (class in blazingmq)

module blazingmq blazingmq.testing

N

NONE (blazingmq.CompressionAlgorithmType attribute) NOT_CONNECTED (blazingmq.AckStatus attribute)

NOT_READY (blazingmq.AckStatus attribute) NOT_SUPPORTED (blazingmq.AckStatus attribute)

O

open_queue() (blazingmq.Session method)

P

post() (blazingmq.Session method) properties (blazingmq.Message attribute) property_types (blazingmq.Message attribute)

PropertyType (class in blazingmq) PropertyTypeDict (in module blazingmq) PropertyValueDict (in module blazingmq)

Q

queue_uri (blazingmq.Ack attribute) (blazingmq.Message attribute) (blazingmq.session_events.QueueEvent attribute) (blazingmq.session_events.QueueReopened attribute) (blazingmq.session_events.QueueReopenFailed attribute) (blazingmq.session_events.QueueResumed attribute) (blazingmq.session_events.QueueResumeFailed attribute) (blazingmq.session_events.QueueSuspended attribute) (blazingmq.session_events.QueueSuspendFailed attribute)

QueueEvent (class in blazingmq.session_events) QueueOptions (class in blazingmq) QueueReopened (class in blazingmq.session_events) QueueReopenFailed (class in blazingmq.session_events) QueueResumed (class in blazingmq.session_events) QueueResumeFailed (class in blazingmq.session_events) QueueSuspended (class in blazingmq.session_events) QueueSuspendFailed (class in blazingmq.session_events)

R

Reconnected (class in blazingmq.session_events)

REFUSED (blazingmq.AckStatus attribute)

S

Session (class in blazingmq) SessionEvent (class in blazingmq.session_events) SessionOptions (class in blazingmq) set_healthy() (blazingmq.BasicHealthMonitor method) set_unhealthy() (blazingmq.BasicHealthMonitor method) SHORT (blazingmq.PropertyType attribute)

SlowConsumerHighWaterMark (class in blazingmq.session_events) SlowConsumerNormal (class in blazingmq.session_events) StateRestored (class in blazingmq.session_events) status (blazingmq.Ack attribute) stop() (blazingmq.Session method) STRING (blazingmq.PropertyType attribute) SUCCESS (blazingmq.AckStatus attribute)

T

TIMEOUT (blazingmq.AckStatus attribute)

Timeouts (class in blazingmq)

U

UNKNOWN (blazingmq.AckStatus attribute)

UNRECOGNIZED (blazingmq.AckStatus attribute)

W

with_options() (blazingmq.Session class method)

Z

ZLIB (blazingmq.CompressionAlgorithmType attribute)