crossbar.bridge.mqtt._events¶

Attributes¶

unicode

Classes¶

`ConnACK`
`Connect`
`ConnectFlags`
`Disconnect`
`Failure`
`PingREQ`
`PingRESP`
`PubACK`
`PubCOMP`
`PubREC`
`PubREL`
`Publish`
`SubACK`
`Subscribe`
`SubscriptionTopicRequest`
`UnsubACK`
`Unsubscribe`

Module Contents¶

class ConnACK[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶: Take an on-wire message and turn it into an instance of this class.

return_code[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

session_present[source]¶

class Connect[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

client_id[source]¶

classmethod deserialise(flags, data)[source]¶: Disassemble from an on-wire message.

flags[source]¶

keep_alive[source]¶

password[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

username[source]¶

will_message[source]¶

will_topic[source]¶

class ConnectFlags[source]¶

Bases: object

clean_session[source]¶

classmethod deserialise(data)[source]¶

password[source]¶

reserved[source]¶

serialise()[source]¶: Assemble this into an on-wire message portion.

username[source]¶

will[source]¶

will_qos[source]¶

will_retain[source]¶

class Disconnect[source]¶

Bases: object

classmethod deserialise(flags, data)[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class Failure[source]¶

Bases: object

reason[source]¶

class PingREQ[source]¶

Bases: object

classmethod deserialise(flags, data)[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class PingRESP[source]¶

Bases: object

classmethod deserialise(flags, data)[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class PubACK[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶: Disassemble from an on-wire message.

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class PubCOMP[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶: Disassemble from an on-wire message.

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class PubREC[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶: Disassemble from an on-wire message.

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class PubREL[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶: Disassemble from an on-wire message.

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class Publish[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶

duplicate[source]¶

packet_identifier[source]¶

payload[source]¶

qos_level[source]¶

retain[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

topic_name[source]¶

class SubACK[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶

packet_identifier[source]¶

return_codes[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class Subscribe[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

topic_requests[source]¶

class SubscriptionTopicRequest[source]¶

Bases: object

max_qos[source]¶

serialise()[source]¶: Assemble this into an on-wire message part.

topic_filter[source]¶

class UnsubACK[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

class Unsubscribe[source]¶

Bases: object

_make_payload()[source]¶: Build the payload from its constituent parts.

classmethod deserialise(flags, data)[source]¶

packet_identifier[source]¶

serialise()[source]¶: Assemble this into an on-wire message.

topics[source]¶

unicode[source]¶