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) {
}
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();
}
return ResponseEntity.ok().build();
}
}
-