package com.l7tech.server.store;

import com.l7tech.policy.assertion.ext.store.KeyValueStoreChangeEventListener;
import com.l7tech.policy.assertion.ext.store.KeyValueStoreChangeEventListener.Callback;
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<Callback>> a = new ConcurrentHashMap<>();

   private a(CustomKeyValueStoreManagerImpl var1) {
   }

   public void add(Callback var1) {
      String var2 = var1.getKeyPrefix();
      Set var3 = this.a.get(var2);
      if (var3 == null) {
         var3 = new CopyOnWriteArraySet();
         this.a.put(var2, var3);
      }

      var3.add(var1);
   }

   public void remove(Callback var1) {
      String var2 = var1.getKeyPrefix();
      Set var3 = this.a.get(var2);
      if (var3 != null) {
         var3.remove(var1);
      }
   }

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