******************************************************************************/\r
\r
\r
-package com.att.research.datarouter.provisioning.utils;\r
+package org.onap.dmaap.datarouter.provisioning.utils;\r
\r
import java.io.IOException;\r
import java.io.InputStream;\r
import javax.servlet.http.HttpServletRequest;\r
import javax.servlet.http.HttpServletResponse;\r
\r
-import com.att.research.datarouter.provisioning.beans.Parameters;\r
-\r
import org.apache.log4j.Logger;\r
import org.eclipse.jetty.continuation.Continuation;\r
import org.eclipse.jetty.continuation.ContinuationSupport;\r
import org.eclipse.jetty.server.AbstractHttpConnection;\r
import org.eclipse.jetty.server.Request;\r
+import org.onap.dmaap.datarouter.provisioning.beans.Parameters;\r
\r
/**\r
* This filter checks /publish requests to the provisioning server to allow ill-behaved publishers to be throttled.\r
public class ThrottleFilter extends TimerTask implements Filter {\r
public static final int DEFAULT_N = 10;\r
public static final int DEFAULT_M = 5;\r
- public static final String THROTTLE_MARKER = "com.att.research.datarouter.provisioning.THROTTLE_MARKER";\r
+ public static final String THROTTLE_MARKER = "org.onap.dmaap.datarouter.provisioning.THROTTLE_MARKER";\r
private static final String JETTY_REQUEST = "org.eclipse.jetty.server.Request";\r
private static final long ONE_MINUTE = 60000L;\r
private static final int ACTION_DROP = 0;\r
private static int m_minutes = 0; // sampling period\r
private static int action = ACTION_DROP; // action to take (throttle or drop)\r
\r
- private static Logger logger = Logger.getLogger("com.att.research.datarouter.provisioning.internal");\r
+ private static Logger logger = Logger.getLogger("org.onap.dmaap.datarouter.provisioning.internal");\r
private static Map<String, Counter> map = new HashMap<String, Counter>();\r
private static final Timer rolex = new Timer();\r
\r