aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java')
-rw-r--r--src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java9
1 files changed, 3 insertions, 6 deletions
diff --git a/src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java b/src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java
index 8b8e50f..55d2175 100644
--- a/src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java
+++ b/src/main/java/org/onap/nbi/apis/listener/ListenerResourceTarget.java
@@ -46,7 +46,7 @@ public class ListenerResourceTarget {
static Map<String, JsonNode> events = new ConcurrentHashMap<>();
/*
- listener resource test for hub resource
+ * listener resource test for hub resource
*/
@PostMapping(consumes = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<Object> postListenerResource(@RequestBody JsonNode event) {
@@ -56,11 +56,9 @@ public class ListenerResourceTarget {
}
try {
Event eventListener = mapper.treeToValue(event, Event.class);
- subscriberRepository
- .findSubscribersUsingEvent(eventListener)
+ subscriberRepository.findSubscribersUsingEvent(eventListener)
.forEach(sub -> notifier.run(sub, eventListener));
- }
- catch(Exception e){
+ } catch (Exception e) {
logger.error("listener not called " + " ," + e.getMessage());
return ResponseEntity.badRequest().build();
}
@@ -68,4 +66,3 @@ public class ListenerResourceTarget {
return ResponseEntity.ok().build();
}
}
-