diff options
| author |   Pamela Dragosh <pd1248@att.com> | 2021-09-03 14:33:20 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2021-09-03 14:33:20 +0000 |
| commit | 7970d563dc8d9c4ea2da5c247b8f5b212146600d (patch) | |
| tree | 600ac6af87957d72ac73b389b4fe99568ce40229 /runtime-controlloop/src/main | |
| parent | 92c1acef612264685104ffff037dfcdf696c0204 (diff) | |
| parent | a84ef3cb2133fde745c50d7a23290505e4f4659a (diff) | |
Merge "Fix eclipse warnings in clamp"
Diffstat (limited to 'runtime-controlloop/src/main')
| -rw-r--r-- | runtime-controlloop/src/main/java/org/onap/policy/clamp/controlloop/runtime/config/messaging/MessageDispatcherActivator.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/runtime-controlloop/src/main/java/org/onap/policy/clamp/controlloop/runtime/config/messaging/MessageDispatcherActivator.java b/runtime-controlloop/src/main/java/org/onap/policy/clamp/controlloop/runtime/config/messaging/MessageDispatcherActivator.java index e0ab2ba91..284094bc4 100644 --- a/runtime-controlloop/src/main/java/org/onap/policy/clamp/controlloop/runtime/config/messaging/MessageDispatcherActivator.java +++ b/runtime-controlloop/src/main/java/org/onap/policy/clamp/controlloop/runtime/config/messaging/MessageDispatcherActivator.java @@ -69,8 +69,8 @@ public class MessageDispatcherActivator extends ServiceManagerContainer implemen // @formatter:off addAction("Topic endpoint management", - () -> TopicEndpointManager.getManager().start(), - () -> TopicEndpointManager.getManager().shutdown()); + () -> TopicEndpointManager.getManager().start(), + () -> TopicEndpointManager.getManager().shutdown()); publishers.forEach(publisher -> addAction("Publisher " + publisher.getClass().getSimpleName(), @@ -79,8 +79,8 @@ public class MessageDispatcherActivator extends ServiceManagerContainer implemen listeners.forEach(listener -> addAction("Listener " + listener.getClass().getSimpleName(), - () -> msgDispatcher.register(listener.getType(), listener.getScoListener()), - () -> msgDispatcher.unregister(listener.getType()))); + () -> msgDispatcher.register(listener.getType(), listener.getScoListener()), + () -> msgDispatcher.unregister(listener.getType()))); addAction("Topic Message Dispatcher", this::registerMsgDispatcher, this::unregisterMsgDispatcher); // @formatter:on |