Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
NONRTRIC - Implement DMaaP mediator producer service in Java
[nonrtric.git]
/
dmaap-adaptor-java
/
src
/
main
/
java
/
org
/
oran
/
dmaapadapter
/
repository
/
Job.java
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
fbeb9cb
..
5f7521c
100644
(file)
--- 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;
@Getter
private BufferTimeout bufferTimeout;
+ private int maxConcurrency;
+
public Parameters() {}
public Parameters() {}
- public Parameters(String filter, BufferTimeout bufferTimeout) {
+ public Parameters(String filter, BufferTimeout bufferTimeout
, int maxConcurrency
) {
this.filter = filter;
this.bufferTimeout = bufferTimeout;
this.filter = filter;
this.bufferTimeout = bufferTimeout;
+ this.maxConcurrency = maxConcurrency;
+ }
+
+ public int getMaxConcurrency() {
+ return maxConcurrency == 0 ? 1 : maxConcurrency;
}
}
@Gson.TypeAdapters
public static class BufferTimeout {
}
}
@Gson.TypeAdapters
public static class BufferTimeout {
- public BufferTimeout(int maxSize,
int
maxTimeMiliseconds) {
+ public BufferTimeout(int maxSize,
long
maxTimeMiliseconds) {
this.maxSize = maxSize;
this.maxTimeMiliseconds = maxTimeMiliseconds;
}
this.maxSize = maxSize;
this.maxTimeMiliseconds = maxTimeMiliseconds;
}
@@
-58,7
+65,7
@@
public class Job {
@Getter
private int maxSize;
@Getter
private int maxSize;
- private
int
maxTimeMiliseconds;
+ private
long
maxTimeMiliseconds;
public Duration getMaxTime() {
return Duration.ofMillis(maxTimeMiliseconds);
public Duration getMaxTime() {
return Duration.ofMillis(maxTimeMiliseconds);