123456789101112131415161718192021222324252627282930313233343536373839404142434445464748 |
- #ifndef UA_NETWORK_MQTT_H_
- #define UA_NETWORK_MQTT_H_
- #ifdef __cplusplus
- extern "C" {
- #endif
- #include "open62541/plugin/pubsub.h"
- #include "open62541/network_tcp.h"
- typedef struct {
- UA_NetworkAddressUrlDataType address;
- UA_UInt32 mqttRecvBufferSize;
- UA_UInt32 mqttSendBufferSize;
- uint8_t *mqttSendBuffer;
- uint8_t *mqttRecvBuffer;
- UA_String *mqttClientId;
- UA_Connection *connection;
- void * mqttClient;
- void (*callback)(UA_ByteString *encodedBuffer, UA_ByteString *topic);
- } UA_PubSubChannelDataMQTT;
-
- UA_PubSubTransportLayer
- UA_PubSubTransportLayerMQTT(void);
- #ifdef __cplusplus
- }
- #endif
- #endif
|