random_client_id(State, Meta, I)
: Create a random client Id of length Ifixed_client_id(State, Meta, Name, Id)
: Create a deterministic client Id with schema Name ++ "-" ++ Idworker_id(State, Meta)
: Get the internal, sequential worker Idclient(State, Meta)
: Get the client Id you set yourself during connection setup with the option {t, client, "client"}connect(State, Meta, ConnectOpts)
: Connect to the broker with the options given in ConnectOptsdisconnect(State, Meta)
: Disconnect normallysubscribe(State, Meta, Topic, QoS)
: Subscribe to Topic with Quality of Service QoSsubscribe_to_self(State, _Meta, TopicPrefix, Qos)
: Subscribe to an exclusive topic, for 1:1 testingunsubscribe(State, Meta, Topic)
: Unubscribe from Topicpublish(State, Meta, Topic, Payload, QoS)
: Publish a message with binary Payload to Topic with QoSpublish(State, Meta, Topic, Payload, QoS, RetainFlag)
: Publish a message with binary Payload to Topic with QoS and RetainFlagpublish_to_self(State, Meta, TopicPrefix, Payload, Qos)
: -> Publish a payload to an exclusive topic, for 1:1 testing