Checking timeout */.

Real heavy lifting jobs for delivering message.

This is thread-safe.

Handle CONNECT.

Handle PUBACK */.

Handle PUBLISH*/ FIXME: support qos = 2.

This is the main place to change if we need to use channel rather than lock.

This function should be called upon starting up.

On connection, if clean session is set, call this method to clear all connections.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Types.

Glabal status */.

InternalId -> Message FIXME: Add code to store G_messages to disk.

Map topic => sub sub is implemented as map, key is client_id, value is qos.

This is the type represents a message should be delivered to specific client */.

This is the type represents a message received from publisher.