From: Arindam Mondal <arind.mondal@samsung.com>
Date: Wed, 22 Aug 2018 01:22:33 +0000 (+0900)
Subject: Fix msgrtr Sonar violation
X-Git-Tag: 1.1.6~3
X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fmessagerouter%2Fmsgrtr.git;a=commitdiff_plain;h=03fd7044fb1475673245560f7708ce23fb642930

Fix msgrtr Sonar violation

Issue-ID: DMAAP-626
Change-Id: Iee10b0e9a9fa14577e796dcd51cdda274dd807a8
Signed-off-by: Arindam Mondal <arind.mondal@samsung.com>
---

diff --git a/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java b/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java
index 4ca6446..e9671ce 100644
--- a/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java
+++ b/src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java
@@ -481,16 +481,16 @@ public class EventsServiceImpl implements EventsService {
 		// 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* 16;
 		String batchlen = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, BATCH_LENGTH);
 		if (null != batchlen)
 			maxEventBatch = Long.parseLong(batchlen);
 		// long maxEventBatch =
 		// ctx.getConfigReader().getSettings().getLong(BATCH_LENGTH, 1024 * 16);
-		final LinkedList<Publisher.message> batch = new LinkedList<Publisher.message>();
+		final LinkedList<Publisher.message> batch = new LinkedList<>();
 		// final ArrayList<KeyedMessage<String, String>> kms = new
 		// ArrayList<KeyedMessage<String, String>>();
-		final ArrayList<ProducerRecord<String, String>> pms = new ArrayList<ProducerRecord<String, String>>();
+		final ArrayList<ProducerRecord<String, String>> pms = new ArrayList<>();
 		try {
 			// for each message...
 			Publisher.message m = null;
@@ -592,7 +592,7 @@ public class EventsServiceImpl implements EventsService {
 		// 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 * 16;
 		String evenlen = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, BATCH_LENGTH);
 		if (null != evenlen)
 			maxEventBatch = Long.parseLong(evenlen);