package org.eclipse.paho.mqttv5.client;

import org.eclipse.paho.mqttv5.client.internal.ClientComms;
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.MqttPublish;

/* JADX INFO: loaded from: classes2.dex */
public class MqttTopic {
    private ClientComms comms;
    private String name;

    public MqttTopic(String str, ClientComms clientComms) {
        this.comms = clientComms;
        this.name = str;
    }

    public MqttToken publish(byte[] bArr, int i, boolean z) throws MqttException {
        MqttMessage mqttMessage = new MqttMessage(bArr);
        mqttMessage.setQos(i);
        mqttMessage.setRetained(z);
        return publish(mqttMessage);
    }

    public MqttToken publish(MqttMessage mqttMessage) throws MqttException {
        MqttToken mqttToken = new MqttToken(this.comms.getClient().getClientId());
        mqttToken.internalTok.setDeliveryToken(true);
        mqttToken.setMessage(mqttMessage);
        this.comms.sendNoWait(createPublish(mqttMessage, new MqttProperties()), mqttToken);
        mqttToken.internalTok.waitUntilSent();
        return mqttToken;
    }

    public String getName() {
        return this.name;
    }

    private MqttPublish createPublish(MqttMessage mqttMessage, MqttProperties mqttProperties) {
        return new MqttPublish(getName(), mqttMessage, mqttProperties);
    }

    public String toString() {
        return getName();
    }
}