/*
 * Decompiled with CFR 0.152.
 * 
 * Could not load the following classes:
 *  com.l7tech.policy.assertion.ext.store.KeyValueStoreChangeEventListener
 *  com.l7tech.policy.assertion.ext.store.KeyValueStoreChangeEventListener$Callback
 */
package com.l7tech.server.store;

import com.l7tech.policy.assertion.ext.store.KeyValueStoreChangeEventListener;
import com.l7tech.server.store.CustomKeyValueStoreManagerImpl;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArraySet;

class a
extends KeyValueStoreChangeEventListener {
    private final Map<String, Set<KeyValueStoreChangeEventListener.Callback>> a = new ConcurrentHashMap<String, Set<KeyValueStoreChangeEventListener.Callback>>();

    private a(CustomKeyValueStoreManagerImpl customKeyValueStoreManagerImpl) {
    }

    public void add(KeyValueStoreChangeEventListener.Callback callback) {
        String string = callback.getKeyPrefix();
        Set<KeyValueStoreChangeEventListener.Callback> set = this.a.get(string);
        if (set == null) {
            set = new CopyOnWriteArraySet<KeyValueStoreChangeEventListener.Callback>();
            this.a.put(string, set);
        }
        set.add(callback);
    }

    public void remove(KeyValueStoreChangeEventListener.Callback callback) {
        String string = callback.getKeyPrefix();
        Set<KeyValueStoreChangeEventListener.Callback> set = this.a.get(string);
        if (set != null) {
            set.remove(callback);
        }
    }

    private Map<String, Set<KeyValueStoreChangeEventListener.Callback>> a() {
        return this.a;
    }
}