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 |