/******************************************************************************* * Copyright (c) 2009, 2017 IBM Corp. * * All rights reserved. This program and the accompanying materials * are made available under the terms of the Eclipse Public License v1.0 * and Eclipse Distribution License v1.0 which accompany this distribution. * * The Eclipse Public License is available at * http://www.eclipse.org/legal/epl-v10.html * and the Eclipse Distribution License is available at * http://www.eclipse.org/org/documents/edl-v10.php. * * Contributors: * Ian Craggs - initial API and implementation and/or initial documentation * Ian Craggs, Allan Stockdill-Mander - SSL updates * Ian Craggs - MQTT 3.1.1 support * Ian Craggs - SNI support *******************************************************************************/ #if !defined(MQTTPROTOCOLOUT_H) #define MQTTPROTOCOLOUT_H #include "LinkedList.h" #include "MQTTPacket.h" #include "Clients.h" #include "Log.h" #include "Messages.h" #include "MQTTProtocol.h" #include "MQTTProtocolClient.h" #define DEFAULT_PORT 1883 char* MQTTProtocol_addressPort(const char* uri, int* port); void MQTTProtocol_reconnect(const char* ip_address, Clients* client); #if defined(OPENSSL) int MQTTProtocol_connect(const char* ip_address, Clients* acClients, int ssl, int MQTTVersion); #else int MQTTProtocol_connect(const char* ip_address, Clients* acClients, int MQTTVersion); #endif int MQTTProtocol_handlePingresps(void* pack, int sock); int MQTTProtocol_subscribe(Clients* client, List* topics, List* qoss, int msgID); int MQTTProtocol_handleSubacks(void* pack, int sock); int MQTTProtocol_unsubscribe(Clients* client, List* topics, int msgID); int MQTTProtocol_handleUnsubacks(void* pack, int sock); #endif