MqttClient Member List
This is the complete list of members for MqttClient, including all inherited members.
autoSelfDestruct | TcpConnection | protected |
buffer | TcpClient | protected |
canSend | TcpConnection | protected |
close() override | TcpClient | protectedvirtual |
commit() | TcpClient | inlineprotected |
connect(const Url &url, const String &uniqueClientName) | MqttClient | |
TcpClient::connect(const String &server, int port, bool useSsl=false) override | TcpClient | protectedvirtual |
TcpClient::connect(IpAddress addr, uint16_t port, bool useSsl=false) override | TcpClient | protectedvirtual |
flush() | TcpConnection | protected |
freeStreams() | TcpClient | protected |
getAvailableWriteSize() | TcpConnection | inlineprotected |
getConnectionState() | TcpClient | inlineprotected |
getRemoteIp() const | TcpConnection | inlineprotected |
getRemotePort() const | TcpConnection | inlineprotected |
getSsl() | TcpConnection | inlineprotected |
initialize(tcp_pcb *pcb) | TcpConnection | protected |
internalConnect(IpAddress addr, uint16_t port) | TcpConnection | protected |
internalOnConnected(err_t err) | TcpConnection | protected |
internalOnDnsResponse(const char *name, LWIP_IP_ADDR_T *ipaddr, int port) | TcpConnection | protected |
internalOnError(err_t err) | TcpConnection | protected |
internalOnPoll() | TcpConnection | protected |
internalOnReceive(pbuf *p, err_t err) | TcpConnection | protected |
internalOnSent(uint16_t len) | TcpConnection | protected |
isProcessing() | TcpClient | inlineprotected |
joinMulticastGroup(IpAddress localIp, IpAddress multicastIp) | IpConnection | protected |
joinMulticastGroup(IpAddress multicastIp) | IpConnection | inlineprotected |
leaveMulticastGroup(IpAddress localIp, IpAddress multicastIp) | IpConnection | protected |
leaveMulticastGroup(IpAddress multicastIp) | IpConnection | inlineprotected |
MqttClient(bool withDefaultPayloadParser=true, bool autoDestruct=false) | MqttClient | |
onClosed() override | TcpClient | protectedvirtual |
onConnected(err_t err) override | TcpClient | protectedvirtual |
onError(err_t err) override | TcpClient | protectedvirtual |
onFinished(TcpClientState finishState) override | MqttClient | protectedvirtual |
onPoll() | TcpConnection | protectedvirtual |
onReadyToSendData(TcpConnectionEvent sourceEvent) override | MqttClient | protectedvirtual |
onReceive(pbuf *buf) override | TcpClient | protectedvirtual |
onSent(uint16_t len) override | TcpClient | protectedvirtual |
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) | MqttClient | inline |
pushAsyncPart() | TcpClient | protected |
send(const char *data, uint16_t len, bool forceCloseAfterSent=false) | TcpClient | protected |
sendString(const String &data, bool forceCloseAfterSent=false) | TcpClient | inlineprotected |
setBuffer(ReadWriteStream *stream) | TcpClient | protected |
setCallback(MqttStringSubscriptionCallback subscriptionCallback=nullptr) | MqttClient | inline |
setCloseAfterSent(bool ignoreIncomingData=false) | TcpClient | inlineprotected |
setCompleteDelegate(TcpClientCompleteDelegate completeCb=nullptr) | TcpClient | inlineprotected |
setConnectedHandler(MqttDelegate handler) | MqttClient | inline |
setDestroyedDelegate(TcpConnectionDestroyedDelegate destroyedDelegate) | TcpConnection | inlineprotected |
setDisconnectHandler(TcpClientCompleteDelegate handler) | MqttClient | inline |
setEventHandler(mqtt_type_t type, MqttDelegate handler) | MqttClient | inline |
setKeepAlive(uint16_t seconds) | MqttClient | inline |
setMessageHandler(MqttDelegate handler) | MqttClient | inline |
setPayloadParser(MqttPayloadParser payloadParser=nullptr) | MqttClient | inline |
setPingRepeatTime(uint16_t seconds) | MqttClient | inline |
setPublishedHandler(MqttDelegate handler) | MqttClient | inline |
setReceiveDelegate(TcpClientDataDelegate receiveCb=nullptr) | TcpClient | inlineprotected |
setSslConnection(Ssl::Connection *connection) | TcpConnection | inlineprotected |
setSslInitHandler(Ssl::Session::InitDelegate handler) | TcpConnection | inlineprotected |
setTimeOut(uint16_t waitTimeOut) | TcpConnection | protected |
setWill(const String &topic, const String &message, uint8_t flags=0) | MqttClient | |
setWill(const String &topic, const String &message, int QoS, bool retained=false) | MqttClient | inline |
sleep | TcpConnection | protected |
ssl | TcpConnection | protected |
sslCreateSession() | TcpConnection | protected |
sslInit | TcpConnection | protected |
sslInitSession(Ssl::Session &session) | TcpConnection | inlineprotectedvirtual |
stream | TcpClient | protected |
subscribe(const String &topic) | MqttClient | |
tcp | TcpConnection | protected |
TcpClient(bool autoDestruct) | TcpClient | inlineprotected |
TcpClient(tcp_pcb *clientTcp, TcpClientDataDelegate clientReceive, TcpClientCompleteDelegate onCompleted) | TcpClient | inlineprotected |
TcpClient(TcpClientCompleteDelegate onCompleted, TcpClientEventDelegate onReadyToSend, TcpClientDataDelegate onReceive=nullptr) | TcpClient | inlineprotected |
TcpClient(TcpClientCompleteDelegate onCompleted, TcpClientDataDelegate onReceive=nullptr) | TcpClient | inlineprotected |
TcpClient(TcpClientDataDelegate onReceive) | TcpClient | inlineexplicitprotected |
TcpConnection(bool autoDestruct) | TcpConnection | inlineprotected |
TcpConnection(tcp_pcb *connection, bool autoDestruct) | TcpConnection | inlineprotected |
timeOut | TcpConnection | protected |
trySend(TcpConnectionEvent event) | TcpConnection | inlineprotected |
unsubscribe(const String &topic) | MqttClient | |
useSsl | TcpConnection | protected |
write(const char *data, int len, uint8_t apiflags=TCP_WRITE_FLAG_COPY) | TcpConnection | protectedvirtual |
write(IDataSourceStream *stream) | TcpConnection | protected |
writeString(const char *data, uint8_t apiflags=TCP_WRITE_FLAG_COPY) | TcpConnection | inlineprotected |
writeString(const String &data, uint8_t apiflags=TCP_WRITE_FLAG_COPY) | TcpConnection | inlineprotected |
~MqttClient() | MqttClient | |
~TcpClient() | TcpClient | inlineprotected |
~TcpConnection() | TcpConnection | protectedvirtual |