summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorParshad Patel <pars.patel@samsung.com>2019-03-12 16:59:50 +0900
committerParshad Patel <pars.patel@samsung.com>2019-03-12 17:02:27 +0900
commit4787fb499d29814267218ddf4d8de1c5880d6657 (patch)
tree59bf2f16bb65212df2fd7687e18f15a05ede171f
parentb1926b2ba40019232e0e3cad83fe54ba6722ea78 (diff)
Fix sonar issues in dmaap/messagerouter/msgrtr
Fix Remove this throw statement from this finally block issue Fix Cast one of the operands of this multiplication operation to a "long" issue Issue-ID: DMAAP-894 Change-Id: Ibd0f9a04e409f0de05e8cf42695188b0e8a1f201 Signed-off-by: Parshad Patel <pars.patel@samsung.com>
-rw-r--r--src/main/java/org/onap/dmaap/dmf/mr/beans/DMaaPKafkaConsumerFactory.java2
-rw-r--r--src/main/java/org/onap/dmaap/dmf/mr/service/impl/MMServiceImpl.java2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/org/onap/dmaap/dmf/mr/beans/DMaaPKafkaConsumerFactory.java b/src/main/java/org/onap/dmaap/dmf/mr/beans/DMaaPKafkaConsumerFactory.java
index 0a909ff..63e065f 100644
--- a/src/main/java/org/onap/dmaap/dmf/mr/beans/DMaaPKafkaConsumerFactory.java
+++ b/src/main/java/org/onap/dmaap/dmf/mr/beans/DMaaPKafkaConsumerFactory.java
@@ -221,7 +221,7 @@ public class DMaaPKafkaConsumerFactory implements ConsumerFactory {
try {
ipLock.release();
} catch (Exception e) {
- throw new UnavailableException("Error while releasing consumer factory lock" + e, e);
+ log.error("Error while releasing consumer factory lock", e);
}
}
}
diff --git a/src/main/java/org/onap/dmaap/dmf/mr/service/impl/MMServiceImpl.java b/src/main/java/org/onap/dmaap/dmf/mr/service/impl/MMServiceImpl.java
index 82ff80a..0ab80c4 100644
--- a/src/main/java/org/onap/dmaap/dmf/mr/service/impl/MMServiceImpl.java
+++ b/src/main/java/org/onap/dmaap/dmf/mr/service/impl/MMServiceImpl.java
@@ -435,7 +435,7 @@ public class MMServiceImpl implements MMService {
// start processing, building a batch to push to the backend
final long startMs = System.currentTimeMillis();
long count = 0;
- long maxEventBatch = 1024 * 16;
+ long maxEventBatch = 1024L * 16L;
String evenlen = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, BATCH_LENGTH);
if (null != evenlen)
maxEventBatch = Long.parseLong(evenlen);