summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att
diff options
context:
space:
mode:
authorArindam Mondal <arind.mondal@samsung.com>2018-08-22 10:22:33 +0900
committerONAP <arind.mondal@samsung.com>2018-08-22 10:22:41 +0900
commit03fd7044fb1475673245560f7708ce23fb642930 (patch)
tree2beb2f79f8804ae2aced79c9357dfd8f4dfe0485 /src/main/java/com/att
parentde1b2f35e38fef975ec0bdb0a63fbf7bb9bd960e (diff)
Fix msgrtr Sonar violation
Issue-ID: DMAAP-626 Change-Id: Iee10b0e9a9fa14577e796dcd51cdda274dd807a8 Signed-off-by: Arindam Mondal <arind.mondal@samsung.com>
Diffstat (limited to 'src/main/java/com/att')
-rw-r--r--src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java8
1 files changed, 4 insertions, 4 deletions
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);