An intPayload implements proto.Payload, and is an int64 that formats itself and then prints itself into the payload.

A ClientConn holds all the state associated with a connection to an MQTT server. It should be allocated via NewClientConn. Concurrent access to a Clie

A Server holds all the state associated with an MQTT server.

An IncomingConn represents a connection into a Server.

A post is a unit of work for the subscription processing workers.

A retain holds information necessary to correctly manage retained messages. This needs to hold copies of the proto.Publish, not pointers to it, or el