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

import java.util.Enumeration;
import java.util.Hashtable;
import org.eclipse.paho.mqttv5.client.MqttClientPersistence;
import org.eclipse.paho.mqttv5.common.MqttPersistable;
import org.eclipse.paho.mqttv5.common.MqttPersistenceException;

/* JADX INFO: loaded from: classes2.dex */
public class MemoryPersistence implements MqttClientPersistence {
    private Hashtable<String, MqttPersistable> data;

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public void close() throws MqttPersistenceException {
        Hashtable<String, MqttPersistable> hashtable = this.data;
        if (hashtable != null) {
            hashtable.clear();
        }
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public Enumeration<String> keys() throws MqttPersistenceException {
        checkIsOpen();
        return this.data.keys();
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public MqttPersistable get(String str) throws MqttPersistenceException {
        checkIsOpen();
        return this.data.get(str);
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public void open(String str) throws MqttPersistenceException {
        this.data = new Hashtable<>();
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public void put(String str, MqttPersistable mqttPersistable) throws MqttPersistenceException {
        checkIsOpen();
        this.data.put(str, mqttPersistable);
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public void remove(String str) throws MqttPersistenceException {
        checkIsOpen();
        this.data.remove(str);
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public void clear() throws MqttPersistenceException {
        checkIsOpen();
        this.data.clear();
    }

    @Override // org.eclipse.paho.mqttv5.client.MqttClientPersistence
    public boolean containsKey(String str) throws MqttPersistenceException {
        checkIsOpen();
        return this.data.containsKey(str);
    }

    private void checkIsOpen() throws MqttPersistenceException {
        if (this.data == null) {
            throw new MqttPersistenceException();
        }
    }
}