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 "Implement secure communications"
[nonrtric.git]
/
dmaap-adaptor-java
/
src
/
main
/
java
/
org
/
oran
/
dmaapadapter
/
tasks
/
ProducerRegstrationTask.java
diff --git
a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java
b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java
index
837ca32
..
4a68ab0
100644
(file)
--- a/
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java
+++ b/
dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/ProducerRegstrationTask.java
@@
-71,7
+71,7
@@
public class ProducerRegstrationTask {
@Scheduled(fixedRate = REGISTRATION_SUPERVISION_INTERVAL_MS)
public void supervisionTask() {
checkRegistration() //
@Scheduled(fixedRate = REGISTRATION_SUPERVISION_INTERVAL_MS)
public void supervisionTask() {
checkRegistration() //
- .filter(isRegist
erred -> !isRegisterred
) //
+ .filter(isRegist
rationOk -> !isRegistrationOk || !this.isRegisteredInEcs
) //
.flatMap(isRegisterred -> registerTypesAndProducer()) //
.subscribe( //
null, //
.flatMap(isRegisterred -> registerTypesAndProducer()) //
.subscribe( //
null, //
@@
-80,13
+80,12
@@
public class ProducerRegstrationTask {
}
private void handleRegistrationCompleted() {
}
private void handleRegistrationCompleted() {
- logger.debug("Registering types and producer
succeed
ed");
+ logger.debug("Registering types and producer
complet
ed");
isRegisteredInEcs = true;
}
private void handleRegistrationFailure(Throwable t) {
isRegisteredInEcs = true;
}
private void handleRegistrationFailure(Throwable t) {
- logger.warn("Registration failed {}", t.getMessage());
- isRegisteredInEcs = false;
+ logger.warn("Registration of producer failed {}", t.getMessage());
}
private Mono<Boolean> checkRegistration() {
}
private Mono<Boolean> checkRegistration() {