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

import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes2.dex */
public class MqttConnectionState {
    private String clientId;
    private Integer receiveMaximum = 65535;
    private Integer maximumQoS = 2;
    private Boolean retainAvailable = true;
    private Long outgoingMaximumPacketSize = null;
    private Long incomingMaximumPacketSize = null;
    private Integer outgoingTopicAliasMaximum = 0;
    private Integer incomingTopicAliasMax = 0;
    private Boolean wildcardSubscriptionsAvailable = true;
    private Boolean subscriptionIdentifiersAvailable = true;
    private Boolean sharedSubscriptionsAvailable = true;
    private boolean sendReasonMessages = false;
    private long keepAlive = 60;
    private AtomicInteger nextOutgoingTopicAlias = new AtomicInteger(1);

    public MqttConnectionState(String str) {
        this.clientId = "";
        this.clientId = str;
    }

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

    public void clearConnectionState() {
        this.nextOutgoingTopicAlias.set(1);
    }

    public Integer getReceiveMaximum() {
        Integer num = this.receiveMaximum;
        if (num == null) {
            return 65535;
        }
        return num;
    }

    public void setReceiveMaximum(Integer num) {
        if (num != null) {
            this.receiveMaximum = num;
        }
    }

    public Integer getMaximumQoS() {
        return this.maximumQoS;
    }

    public void setMaximumQoS(Integer num) {
        if (num != null) {
            this.maximumQoS = num;
        }
    }

    public Boolean isRetainAvailable() {
        return this.retainAvailable;
    }

    public void setRetainAvailable(Boolean bool) {
        if (bool != null) {
            this.retainAvailable = bool;
        }
    }

    public Long getOutgoingMaximumPacketSize() {
        return this.outgoingMaximumPacketSize;
    }

    public void setOutgoingMaximumPacketSize(Long l) {
        if (l != null) {
            this.outgoingMaximumPacketSize = l;
        }
    }

    public Long getIncomingMaximumPacketSize() {
        return this.incomingMaximumPacketSize;
    }

    public void setIncomingMaximumPacketSize(Long l) {
        if (l != null) {
            this.incomingMaximumPacketSize = l;
        }
    }

    public Integer getOutgoingTopicAliasMaximum() {
        return this.outgoingTopicAliasMaximum;
    }

    public void setOutgoingTopicAliasMaximum(Integer num) {
        if (num != null) {
            this.outgoingTopicAliasMaximum = num;
        }
    }

    public Boolean isWildcardSubscriptionsAvailable() {
        return this.wildcardSubscriptionsAvailable;
    }

    public void setWildcardSubscriptionsAvailable(Boolean bool) {
        if (bool != null) {
            this.wildcardSubscriptionsAvailable = bool;
        }
    }

    public Boolean isSubscriptionIdentifiersAvailable() {
        return this.subscriptionIdentifiersAvailable;
    }

    public void setSubscriptionIdentifiersAvailable(Boolean bool) {
        if (bool != null) {
            this.subscriptionIdentifiersAvailable = bool;
        }
    }

    public Boolean isSharedSubscriptionsAvailable() {
        return this.sharedSubscriptionsAvailable;
    }

    public void setSharedSubscriptionsAvailable(Boolean bool) {
        if (bool != null) {
            this.sharedSubscriptionsAvailable = bool;
        }
    }

    public Integer getNextOutgoingTopicAlias() {
        return Integer.valueOf(this.nextOutgoingTopicAlias.getAndIncrement());
    }

    public Integer getIncomingTopicAliasMax() {
        return this.incomingTopicAliasMax;
    }

    public void setIncomingTopicAliasMax(Integer num) {
        if (num != null) {
            this.incomingTopicAliasMax = num;
        }
    }

    public boolean isSendReasonMessages() {
        return this.sendReasonMessages;
    }

    public void setSendReasonMessages(boolean z) {
        this.sendReasonMessages = z;
    }

    public long getKeepAlive() {
        return this.keepAlive;
    }

    public void setKeepAliveSeconds(long j) {
        this.keepAlive = j * 1000;
    }
}