MqttClient Member List

This is the complete list of members for MqttClient, including all inherited members.

autoSelfDestructTcpConnectionprotected
bufferTcpClientprotected
canSendTcpConnectionprotected
close() overrideTcpClientprotectedvirtual
connect(const Url &url, const String &uniqueClientName)MqttClient
TcpClient::connect(const String &server, int port, bool useSsl=false) overrideTcpClientprotectedvirtual
TcpClient::connect(IpAddress addr, uint16_t port, bool useSsl=false) overrideTcpClientprotectedvirtual
flush()TcpConnectionprotected
freeStreams()TcpClientprotected
getAvailableWriteSize()TcpConnectioninlineprotected
getConnectionState()TcpClientinlineprotected
getRemoteIp() constTcpConnectioninlineprotected
getRemotePort() constTcpConnectioninlineprotected
getSsl()TcpConnectioninlineprotected
initialize(tcp_pcb *pcb)TcpConnectionprotected
internalConnect(IpAddress addr, uint16_t port)TcpConnectionprotected
internalOnConnected(err_t err)TcpConnectionprotected
internalOnDnsResponse(const char *name, LWIP_IP_ADDR_T *ipaddr, int port)TcpConnectionprotected
internalOnError(err_t err)TcpConnectionprotected
internalOnPoll()TcpConnectionprotected
internalOnReceive(pbuf *p, err_t err)TcpConnectionprotected
internalOnSent(uint16_t len)TcpConnectionprotected
isProcessing()TcpClientinlineprotected
MqttClient(bool withDefaultPayloadParser=true, bool autoDestruct=false)MqttClient
onConnected(err_t err) overrideTcpClientprotectedvirtual
onError(err_t err) overrideTcpClientprotectedvirtual
onFinished(TcpClientState finishState) overrideMqttClientprotectedvirtual
onPoll()TcpConnectionprotectedvirtual
onReadyToSendData(TcpConnectionEvent sourceEvent) overrideMqttClientprotectedvirtual
onReceive(pbuf *buf) overrideTcpClientprotectedvirtual
onSent(uint16_t len) overrideTcpClientprotectedvirtual
publish(const String &topic, const String &message, uint8_t flags=0)MqttClient
publish(const String &topic, IDataSourceStream *stream, uint8_t flags=0)MqttClient
publishWithQoS(const String &topic, const String &message, int QoS, bool retained=false, MqttMessageDeliveredCallback onDelivery=nullptr)MqttClientinline
pushAsyncPart()TcpClientprotected
send(const char *data, uint16_t len, bool forceCloseAfterSent=false)TcpClientprotected
sendString(const String &data, bool forceCloseAfterSent=false)TcpClientinlineprotected
setBuffer(ReadWriteStream *stream)TcpClientprotected
setCallback(MqttStringSubscriptionCallback subscriptionCallback=nullptr)MqttClientinline
setCloseAfterSent(bool ignoreIncomingData=false)TcpClientinlineprotected
setCompleteDelegate(TcpClientCompleteDelegate completeCb=nullptr)TcpClientinlineprotected
setConnectedHandler(MqttDelegate handler)MqttClientinline
setDestroyedDelegate(TcpConnectionDestroyedDelegate destroyedDelegate)TcpConnectioninlineprotected
setDisconnectHandler(TcpClientCompleteDelegate handler)MqttClientinline
setEventHandler(mqtt_type_t type, MqttDelegate handler)MqttClientinline
setKeepAlive(uint16_t seconds)MqttClientinline
setMessageHandler(MqttDelegate handler)MqttClientinline
setPayloadParser(MqttPayloadParser payloadParser=nullptr)MqttClientinline
setPingRepeatTime(unsigned seconds)MqttClient
setPublishedHandler(MqttDelegate handler)MqttClientinline
setReceiveDelegate(TcpClientDataDelegate receiveCb=nullptr)TcpClientinlineprotected
setSslConnection(Ssl::Connection *connection)TcpConnectioninlineprotected
setSslInitHandler(Ssl::Session::InitDelegate handler)TcpConnectioninlineprotected
setTimeOut(uint16_t waitTimeOut)TcpConnectionprotected
setWill(const String &topic, const String &message, uint8_t flags=0)MqttClient
setWill(const String &topic, const String &message, int QoS, bool retained=false)MqttClientinline
sleepTcpConnectionprotected
sslTcpConnectionprotected
sslCreateSession()TcpConnectionprotected
sslInitTcpConnectionprotected
sslInitSession(Ssl::Session &session)TcpConnectioninlineprotectedvirtual
streamTcpClientprotected
subscribe(const String &topic)MqttClient
tcpTcpConnectionprotected
TcpClient(bool autoDestruct)TcpClientinlineprotected
TcpClient(tcp_pcb *clientTcp, TcpClientDataDelegate clientReceive, TcpClientCompleteDelegate onCompleted)TcpClientinlineprotected
TcpClient(TcpClientCompleteDelegate onCompleted, TcpClientEventDelegate onReadyToSend, TcpClientDataDelegate onReceive=nullptr)TcpClientinlineprotected
TcpClient(TcpClientCompleteDelegate onCompleted, TcpClientDataDelegate onReceive=nullptr)TcpClientinlineprotected
TcpClient(TcpClientDataDelegate onReceive)TcpClientinlineexplicitprotected
TcpConnection(bool autoDestruct)TcpConnectioninlineprotected
TcpConnection(tcp_pcb *connection, bool autoDestruct)TcpConnectioninlineprotected
timeOutTcpConnectionprotected
trySend(TcpConnectionEvent event)TcpConnectioninlineprotected
unsubscribe(const String &topic)MqttClient
useSslTcpConnectionprotected
write(const char *data, int len, uint8_t apiflags=TCP_WRITE_FLAG_COPY)TcpConnectionprotectedvirtual
write(IDataSourceStream *stream)TcpConnectionprotected
writeString(const char *data, uint8_t apiflags=TCP_WRITE_FLAG_COPY)TcpConnectioninlineprotected
writeString(const String &data, uint8_t apiflags=TCP_WRITE_FLAG_COPY)TcpConnectioninlineprotected
~MqttClient()MqttClient
~TcpClient()TcpClientinlineprotected
~TcpConnection()TcpConnectionprotectedvirtual