package org.eclipse.paho.mqttv5.client.internal;

import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes2.dex */
public class MqttSessionState {
    private String clientId;
    private AtomicInteger nextSubscriptionIdentifier = new AtomicInteger(1);

    public void clearSessionState() {
        this.nextSubscriptionIdentifier.set(1);
    }

    public Integer getNextSubscriptionIdentifier() {
        return Integer.valueOf(this.nextSubscriptionIdentifier.getAndIncrement());
    }

    public String getClientId() {
        return this.clientId;
    }

    public void setClientId(String str) {
        this.clientId = str;
    }
}