Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Merge "Add output schema for ODU slice assurance usecase"
[nonrtric.git]
/
dmaap-adaptor-java
/
src
/
main
/
java
/
org
/
oran
/
dmaapadapter
/
repository
/
InfoType.java
diff --git
a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/InfoType.java
b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/InfoType.java
index
9dda1e6
..
27b527d
100644
(file)
--- a/
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/InfoType.java
+++ b/
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/repository/InfoType.java
@@
-22,6
+22,8
@@
package org.oran.dmaapadapter.repository;
import lombok.Getter;
import lombok.Getter;
+import org.springframework.util.StringUtils;
+
public class InfoType {
@Getter
public class InfoType {
@Getter
@@
-33,10
+35,22
@@
public class InfoType {
@Getter
private final boolean useHttpProxy;
@Getter
private final boolean useHttpProxy;
- public InfoType(String id, String dmaapTopicUrl, boolean useHttpProxy) {
+ @Getter
+ private final String kafkaInputTopic;
+
+ public InfoType(String id, String dmaapTopicUrl, boolean useHttpProxy, String kafkaInputTopic) {
this.id = id;
this.dmaapTopicUrl = dmaapTopicUrl;
this.useHttpProxy = useHttpProxy;
this.id = id;
this.dmaapTopicUrl = dmaapTopicUrl;
this.useHttpProxy = useHttpProxy;
+ this.kafkaInputTopic = kafkaInputTopic;
+ }
+
+ public boolean isKafkaTopicDefined() {
+ return StringUtils.hasLength(kafkaInputTopic);
+ }
+
+ public boolean isDmaapTopicDefined() {
+ return StringUtils.hasLength(dmaapTopicUrl);
}
}
}
}