MQTTProtocolOut.h
Go to the documentation of this file.
1 /*******************************************************************************
2  * Copyright (c) 2009, 2020 IBM Corp.
3  *
4  * All rights reserved. This program and the accompanying materials
5  * are made available under the terms of the Eclipse Public License v2.0
6  * and Eclipse Distribution License v1.0 which accompany this distribution.
7  *
8  * The Eclipse Public License is available at
9  * https://www.eclipse.org/legal/epl-2.0/
10  * and the Eclipse Distribution License is available at
11  * http://www.eclipse.org/org/documents/edl-v10.php.
12  *
13  * Contributors:
14  * Ian Craggs - initial API and implementation and/or initial documentation
15  * Ian Craggs, Allan Stockdill-Mander - SSL updates
16  * Ian Craggs - MQTT 3.1.1 support
17  * Ian Craggs - SNI support
18  * Ian Craggs - MQTT 5.0 support
19  *******************************************************************************/
20 
21 #if !defined(MQTTPROTOCOLOUT_H)
22 #define MQTTPROTOCOLOUT_H
23 
24 #include "LinkedList.h"
25 #include "MQTTPacket.h"
26 #include "Clients.h"
27 #include "Log.h"
28 #include "Messages.h"
29 #include "MQTTProtocol.h"
30 #include "MQTTProtocolClient.h"
31 
32 #define MQTT_DEFAULT_PORT 1883
33 #define SECURE_MQTT_DEFAULT_PORT 8883
34 #define WS_DEFAULT_PORT 80
35 
36 size_t MQTTProtocol_addressPort(const char* uri, int* port, const char **topic, int default_port);
37 void MQTTProtocol_reconnect(const char* ip_address, Clients* client);
38 #if defined(OPENSSL)
39 #if defined(__GNUC__) && defined(__linux__)
40 int MQTTProtocol_connect(const char* ip_address, Clients* acClients, int ssl, int websocket, int MQTTVersion,
41  MQTTProperties* connectProperties, MQTTProperties* willProperties, long timeout);
42 #else
43 int MQTTProtocol_connect(const char* ip_address, Clients* acClients, int ssl, int websocket, int MQTTVersion,
44  MQTTProperties* connectProperties, MQTTProperties* willProperties);
45 #endif
46 #else
47 #if defined(__GNUC__) && defined(__linux__)
48 int MQTTProtocol_connect(const char* ip_address, Clients* acClients, int websocket, int MQTTVersion,
49  MQTTProperties* connectProperties, MQTTProperties* willProperties, long timeout);
50 #else
51 int MQTTProtocol_connect(const char* ip_address, Clients* acClients, int websocket, int MQTTVersion,
52  MQTTProperties* connectProperties, MQTTProperties* willProperties);
53 #endif
54 #endif
55 int MQTTProtocol_handlePingresps(void* pack, int sock);
56 int MQTTProtocol_subscribe(Clients* client, List* topics, List* qoss, int msgID,
58 int MQTTProtocol_handleSubacks(void* pack, int sock);
60 int MQTTProtocol_handleUnsubacks(void* pack, int sock);
61 
62 #endif
int MQTTProtocol_connect(const char *ip_address, Clients *acClients, int websocket, int MQTTVersion, MQTTProperties *connectProperties, MQTTProperties *willProperties)
int MQTTProtocol_unsubscribe(Clients *client, List *topics, int msgID, MQTTProperties *props)
string topic
Definition: test2.py:8
MQTTProperties props
Definition: paho_c_pub.c:54
void MQTTProtocol_reconnect(const char *ip_address, Clients *client)
struct pubsub_opts opts
Definition: paho_c_pub.c:42
int MQTTProtocol_handlePingresps(void *pack, int sock)
MQTTAsync client
Definition: test6.c:276
int MQTTProtocol_handleSubacks(void *pack, int sock)
size_t MQTTProtocol_addressPort(const char *uri, int *port, const char **topic, int default_port)
int MQTTProtocol_handleUnsubacks(void *pack, int sock)
int MQTTProtocol_subscribe(Clients *client, List *topics, List *qoss, int msgID, MQTTSubscribe_options *opts, MQTTProperties *props)
char * topics[]


plotjuggler
Author(s): Davide Faconti
autogenerated on Sun Dec 6 2020 03:48:09