package org.eclipse.paho.mqttv5.client;

import org.eclipse.paho.mqttv5.client.util.Debug;
import org.eclipse.paho.mqttv5.common.MqttException;
import org.eclipse.paho.mqttv5.common.MqttMessage;
import org.eclipse.paho.mqttv5.common.MqttSubscription;
import org.eclipse.paho.mqttv5.common.packet.MqttProperties;

/* JADX INFO: loaded from: classes2.dex */
public interface IMqttAsyncClient {
    IMqttToken authenticate(int i, Object obj, MqttProperties mqttProperties) throws MqttException;

    IMqttToken checkPing(Object obj, MqttActionListener mqttActionListener) throws MqttException;

    void close() throws MqttException;

    void close(boolean z) throws MqttException;

    IMqttToken connect() throws MqttException;

    IMqttToken connect(Object obj, MqttActionListener mqttActionListener) throws MqttException;

    IMqttToken connect(MqttConnectionOptions mqttConnectionOptions) throws MqttException;

    IMqttToken connect(MqttConnectionOptions mqttConnectionOptions, Object obj, MqttActionListener mqttActionListener) throws MqttException;

    void deleteBufferedMessage(int i);

    IMqttToken disconnect() throws MqttException;

    IMqttToken disconnect(long j) throws MqttException;

    IMqttToken disconnect(long j, Object obj, MqttActionListener mqttActionListener, int i, MqttProperties mqttProperties) throws MqttException;

    IMqttToken disconnect(Object obj, MqttActionListener mqttActionListener) throws MqttException;

    void disconnectForcibly() throws MqttException;

    void disconnectForcibly(long j) throws MqttException;

    void disconnectForcibly(long j, long j2, int i, MqttProperties mqttProperties) throws MqttException;

    void disconnectForcibly(long j, long j2, boolean z) throws MqttException;

    MqttMessage getBufferedMessage(int i);

    int getBufferedMessageCount();

    String getClientId();

    String getCurrentServerURI();

    Debug getDebug();

    int getInFlightMessageCount();

    IMqttToken[] getPendingTokens();

    String getServerURI();

    boolean isConnected();

    void messageArrivedComplete(int i, int i2) throws MqttException;

    IMqttToken publish(String str, MqttMessage mqttMessage) throws MqttException;

    IMqttToken publish(String str, MqttMessage mqttMessage, Object obj, MqttActionListener mqttActionListener) throws MqttException;

    IMqttToken publish(String str, byte[] bArr, int i, boolean z) throws MqttException;

    IMqttToken publish(String str, byte[] bArr, int i, boolean z, Object obj, MqttActionListener mqttActionListener) throws MqttException;

    void reconnect() throws MqttException;

    void setBufferOpts(DisconnectedBufferOptions disconnectedBufferOptions);

    void setCallback(MqttCallback mqttCallback);

    void setClientId(String str);

    void setManualAcks(boolean z);

    IMqttToken subscribe(String str, int i) throws MqttException;

    IMqttToken subscribe(String str, int i, Object obj, MqttActionListener mqttActionListener) throws MqttException;

    IMqttToken subscribe(MqttSubscription mqttSubscription) throws MqttException;

    IMqttToken subscribe(MqttSubscription mqttSubscription, Object obj, MqttActionListener mqttActionListener, IMqttMessageListener iMqttMessageListener, MqttProperties mqttProperties) throws MqttException;

    IMqttToken subscribe(MqttSubscription mqttSubscription, IMqttMessageListener iMqttMessageListener) throws MqttException;

    IMqttToken subscribe(String[] strArr, int[] iArr) throws MqttException;

    IMqttToken subscribe(String[] strArr, int[] iArr, Object obj, MqttActionListener mqttActionListener) throws MqttException;

    IMqttToken subscribe(MqttSubscription[] mqttSubscriptionArr) throws MqttException;

    IMqttToken subscribe(MqttSubscription[] mqttSubscriptionArr, Object obj, MqttActionListener mqttActionListener, IMqttMessageListener iMqttMessageListener, MqttProperties mqttProperties) throws MqttException;

    IMqttToken subscribe(MqttSubscription[] mqttSubscriptionArr, Object obj, MqttActionListener mqttActionListener, MqttProperties mqttProperties) throws MqttException;

    IMqttToken subscribe(MqttSubscription[] mqttSubscriptionArr, Object obj, MqttActionListener mqttActionListener, IMqttMessageListener[] iMqttMessageListenerArr, MqttProperties mqttProperties) throws MqttException;

    IMqttToken subscribe(MqttSubscription[] mqttSubscriptionArr, IMqttMessageListener iMqttMessageListener) throws MqttException;

    IMqttToken unsubscribe(String str) throws MqttException;

    IMqttToken unsubscribe(String str, Object obj, MqttActionListener mqttActionListener) throws MqttException;

    IMqttToken unsubscribe(String[] strArr) throws MqttException;

    IMqttToken unsubscribe(String[] strArr, Object obj, MqttActionListener mqttActionListener, MqttProperties mqttProperties) throws MqttException;
}