X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fservice%2Fimpl%2FMMServiceImpl.java;h=0ab80c4035c7ceafa866631da0f1b3ace6dd52fc;hb=4787fb499d29814267218ddf4d8de1c5880d6657;hp=d862677b0a6d4ad1758da38dfab389bec3b2b520;hpb=3504265229c589ecc166e3ad4c33bb198b11e4ce;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

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 d862677..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
@@ -349,7 +349,7 @@ public class MMServiceImpl implements MMService {
 		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);
@@ -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);