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
/
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
..
8216769
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() {
@@
-112,8
+111,8
@@
public class ProducerRegstrationTask {
private Mono<String> registerTypesAndProducer() {
final int CONCURRENCY = 20;
private Mono<String> registerTypesAndProducer() {
final int CONCURRENCY = 20;
- final String producerUrl =
-
applicationConfig.getEcsBaseUrl() + "/data-producer/v1/info-producers/"
+ PRODUCER_ID;
+ final String producerUrl =
applicationConfig.getEcsBaseUrl() + "/data-producer/v1/info-producers/"
+ + PRODUCER_ID;
return Flux.fromIterable(this.types.getAll()) //
.doOnNext(type -> logger.info("Registering type {}", type.getId())) //
return Flux.fromIterable(this.types.getAll()) //
.doOnNext(type -> logger.info("Registering type {}", type.getId())) //