MQTT Input Context

//Publish a binary payload with QOS and retained flag
void publish(String topic, byte[] payload, int qos, boolean retained);

//Publish a binary payload with QOS
void publish(String topic, byte[] payload, int qos);

//Publish a binary payload
void publish(String topic, byte[] payload);

//Publish a text payload with QOS and retain flag
void publish(String topic, String payload, int qos, boolean retained);

//Publish a text payload with QOS
void publish(String topic, String payload, int qos);

//Publish a text payload
void publish(String topic, String payload);

//Stops the input service
void stop();

//Gets the input service's config ID
String getId();

//Retrieves the entity type [DOMAIN, ORGANIZATION, GLOBAL, SYSTEM]
EntityType getEntityType();

//Gets the input service's org id 
Long getOrgId();