summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/dmf
diff options
context:
space:
mode:
authorRam Koya <rk541m@att.com>2018-09-18 13:21:33 +0000
committerGerrit Code Review <gerrit@onap.org>2018-09-18 13:21:33 +0000
commit6ec5b11a771df8e68719a4043b208cf5497bd553 (patch)
tree194b3be5d39fda36d85db6aa388c673d8336a416 /src/main/java/com/att/dmf
parent5f44e83da5f3d80de890bc3d48968d92e3ce7b91 (diff)
parent8c749d9c6c5da0d1df2662d664e70b18498e076e (diff)
Merge "Sonar Major issues"1.1.9
Diffstat (limited to 'src/main/java/com/att/dmf')
-rw-r--r--src/main/java/com/att/dmf/mr/service/impl/MMServiceImpl.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/att/dmf/mr/service/impl/MMServiceImpl.java b/src/main/java/com/att/dmf/mr/service/impl/MMServiceImpl.java
index da8cb16..e55f510 100644
--- a/src/main/java/com/att/dmf/mr/service/impl/MMServiceImpl.java
+++ b/src/main/java/com/att/dmf/mr/service/impl/MMServiceImpl.java
@@ -114,7 +114,7 @@ public class MMServiceImpl implements MMService {
throws ConfigDbException, TopicExistsException, AccessDeniedException, UnavailableException,
CambriaApiException, IOException {
- // final long startTime = System.currentTimeMillis();
+
final HttpServletRequest req = ctx.getRequest();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
@@ -138,13 +138,13 @@ public class MMServiceImpl implements MMService {
limit = Integer.parseInt(req.getParameter("limit"));
}
limit = 1;
- // int timeoutMs = 60000;
+
int timeoutMs = CambriaConstants.kNoTimeout;
String strtimeoutMS = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "timeout");
if (strtimeoutMS != null)
timeoutMs = Integer.parseInt(strtimeoutMS);
// int timeoutMs = ctx.getConfigReader().getSettings().getInt("timeout",
- // CambriaConstants.kNoTimeout);
+
if (req.getParameter("timeout") != null) {
timeoutMs = Integer.parseInt(req.getParameter("timeout"));
}