diff options
| author |   Arindam Mondal <arind.mondal@samsung.com> | 2018-08-22 10:22:33 +0900 |
|---|---|---|
| committer | ONAP <arind.mondal@samsung.com> | 2018-08-22 10:22:41 +0900 |
| commit | 03fd7044fb1475673245560f7708ce23fb642930 (patch) | |
| tree | 2beb2f79f8804ae2aced79c9357dfd8f4dfe0485 /src/main/java/com/att | |
| parent | de1b2f35e38fef975ec0bdb0a63fbf7bb9bd960e (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.java | 8 |
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); |