X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdatarouter.git;a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Futils%2FThrottleFilter.java;h=f0f10671a82a5f9647e844bafac08101dae579f7;hp=659dbacdc947ddfcfd9b037c350ad5bf3f2cb16e;hb=8280a5e1a6cfd155edfafe882439b8c04c6a4509;hpb=1c11dffada48c31491f2583f0d28ccecb4b4891b diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/ThrottleFilter.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/ThrottleFilter.java index 659dbacd..f0f10671 100644 --- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/ThrottleFilter.java +++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/utils/ThrottleFilter.java @@ -104,6 +104,7 @@ public class ThrottleFilter extends TimerTask implements Filter { private static EELFLogger logger = EELFManager.getInstance().getLogger("InternalLog"); private static Map map = new HashMap<>(); + private Map> suspendedRequests = new HashMap<>(); private static final Timer rolex = new Timer(); @Override @@ -229,8 +230,6 @@ public class ThrottleFilter extends TimerTask implements Filter { } } - private Map> suspendedRequests = new HashMap<>(); - private void register(String id, Continuation continuation) { synchronized (suspendedRequests) { List list = suspendedRequests.get(id);