package org.eclipse.paho.mqttv5.client;

import org.eclipse.paho.mqttv5.client.internal.Token;
import org.eclipse.paho.mqttv5.common.MqttException;
import org.eclipse.paho.mqttv5.common.MqttMessage;
import org.eclipse.paho.mqttv5.common.packet.MqttProperties;
import org.eclipse.paho.mqttv5.common.packet.MqttWireMessage;

/* JADX INFO: loaded from: classes2.dex */
public class MqttToken implements IMqttToken {
    private MqttAsyncClient client;
    public Token internalTok;

    public MqttToken() {
        this.client = null;
        this.internalTok = null;
    }

    public MqttToken(MqttAsyncClient mqttAsyncClient) {
        this.internalTok = null;
        this.client = mqttAsyncClient;
    }

    public MqttToken(String str) {
        this.client = null;
        this.internalTok = null;
        this.internalTok = new Token(str);
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttException getException() {
        return this.internalTok.getException();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public boolean isComplete() {
        return this.internalTok.isComplete();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public void setActionCallback(MqttActionListener mqttActionListener) {
        this.internalTok.setActionCallback(mqttActionListener);
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttActionListener getActionCallback() {
        return this.internalTok.getActionCallback();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public void waitForCompletion() throws MqttException {
        this.internalTok.waitForCompletion(-1L);
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public void waitForCompletion(long j) throws MqttException {
        this.internalTok.waitForCompletion(j);
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttClientInterface getClient() {
        return this.internalTok.getClient();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public String[] getTopics() {
        return this.internalTok.getTopics();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public Object getUserContext() {
        return this.internalTok.getUserContext();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public void setUserContext(Object obj) {
        this.internalTok.setUserContext(obj);
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public int getMessageId() {
        return this.internalTok.getMessageID();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public int[] getGrantedQos() {
        return this.internalTok.getGrantedQos();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public boolean getSessionPresent() {
        return this.internalTok.getSessionPresent();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttWireMessage getResponse() {
        return this.internalTok.getResponse();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttProperties getResponseProperties() {
        if (this.internalTok.getWireMessage() == null) {
            return null;
        }
        return this.internalTok.getWireMessage().getProperties();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttWireMessage getRequestMessage() {
        return this.internalTok.getRequestMessage();
    }

    public void setRequestMessage(MqttWireMessage mqttWireMessage) {
        this.internalTok.setRequestMessage(mqttWireMessage);
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttProperties getRequestProperties() {
        if (this.internalTok.getRequestMessage() == null) {
            return null;
        }
        return this.internalTok.getRequestMessage().getProperties();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public int[] getReasonCodes() {
        return this.internalTok.getReasonCodes();
    }

    @Override // org.eclipse.paho.mqttv5.client.IMqttToken
    public MqttMessage getMessage() throws MqttException {
        return this.internalTok.getMessage();
    }

    protected void setMessage(MqttMessage mqttMessage) {
        this.internalTok.setMessage(mqttMessage);
    }
}