X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-adaptor-java%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fdmaapadapter%2Frepository%2FJob.java;h=5f7521c37fabfb6af267d7c1a8043292913f5995;hb=b3896f4ad7912be9e12c05e7d4770fa39752d797;hp=fbeb9cbc4962a799702077023b3a302dd02a72da;hpb=5e1623ab25b62c6c28849bfd862eba4648465922;p=nonrtric.git

diff --git a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Job.java b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Job.java
index fbeb9cbc..5f7521c3 100644
--- a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Job.java
+++ b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/Job.java
@@ -38,17 +38,24 @@ public class Job {
         @Getter
         private BufferTimeout bufferTimeout;
 
+        private int maxConcurrency;
+
         public Parameters() {}
 
-        public Parameters(String filter, BufferTimeout bufferTimeout) {
+        public Parameters(String filter, BufferTimeout bufferTimeout, int maxConcurrency) {
             this.filter = filter;
             this.bufferTimeout = bufferTimeout;
+            this.maxConcurrency = maxConcurrency;
+        }
+
+        public int getMaxConcurrency() {
+            return maxConcurrency == 0 ? 1 : maxConcurrency;
         }
     }
 
     @Gson.TypeAdapters
     public static class BufferTimeout {
-        public BufferTimeout(int maxSize, int maxTimeMiliseconds) {
+        public BufferTimeout(int maxSize, long maxTimeMiliseconds) {
             this.maxSize = maxSize;
             this.maxTimeMiliseconds = maxTimeMiliseconds;
         }
@@ -58,7 +65,7 @@ public class Job {
         @Getter
         private int maxSize;
 
-        private int maxTimeMiliseconds;
+        private long maxTimeMiliseconds;
 
         public Duration getMaxTime() {
             return Duration.ofMillis(maxTimeMiliseconds);