Navigation
API > API/Plugins > API/Plugins/MQTTCore
References
| Module | MQTTCore |
| Header | /Engine/Plugins/Protocols/MQTT/Source/MQTTCore/Public/IMQTTClient.h |
| Include | #include "IMQTTClient.h" |
Syntax
class IMQTTClient
Destructors
| Type | Name | Description | |
|---|---|---|---|
~IMQTTClient () |
Functions
| Type | Name | Description | |
|---|---|---|---|
| TFuture< EMQTTConnectReturnCode > | Connect
(
bool bCleanSession |
Connect using the clients URL. Set bCleanSession = false to resume previous session. | |
| TFuture< void > | Disconnect () |
Virtual TCancellablePromise |
|
| FGuid | GetClientId () |
Unique Id for this client. | |
| const FMQTTURL & | GetURL () |
URL for this client. | |
| bool | IsConnected () |
Is client currently connected? | |
| bool | IsValid () |
Validity of this client. | |
| FOnConnect & | OnConnect () |
||
| FOnDisconnect & | OnDisconnect () |
||
| FOnMessage & | OnMessage () |
||
| FOnPublish & | OnPublish () |
||
| FOnSubscribe & | OnSubscribe () |
||
| FOnUnsubscribe & | |||
| TFuture< bool > | Ping
(
const float& InTimeout |
Returns true if response received before timeout. | |
| TFuture< bool > |
Publish
(
const FString& InTopic, |
Return true if the entire operation was successful (depends on QoS) | |
| TFuture< bool > |
Publish
(
const FString& InTopic, |
Return true if the entire operation was successful (depends on QoS) | |
| TFuture< TArray< FMQTTSubscribeResult > > | Subscribe
(
const TArray< TPair< FString, EMQTTQualityOfService >>& InTopicFilterQoSPairs |
||
| TFuture< FMQTTSubscribeResult > | Subscribe
(
const FString& InTopicFilter, |
Only for single sub | |
| TFuture< bool > | Unsubscribe
(
const TSet< FString >& InTopicFilters |
Typedefs
| Name | Description |
|---|---|
| FOnConnect | |
| FOnDisconnect | |
| FOnMessage | |
| FOnPublish | |
| FOnSubscribe | |
| FOnUnsubscribe |