X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fmessagebus-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmessagebus%2Fapp%2Fimpl%2FTopic.java;h=a32413064e429403aeaa9a032845e3a34ee8fbde;hb=5c008222efa5c0af49cf8a52881a6299b1e249dc;hp=aebde0c0432df8fb3f75085f8cc749d0b8e39bdc;hpb=22c6645e0793c65ba1f0c1004d79cf83e770d765;p=controller.git diff --git a/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/Topic.java b/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/Topic.java index aebde0c043..a32413064e 100644 --- a/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/Topic.java +++ b/opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/Topic.java @@ -63,10 +63,7 @@ public class Topic implements DataChangeListener { public void notifyNode(final NodeId nodeId) { JoinTopicInput jti = getJoinTopicInputArgument(nodeId); EventSourceService ess = mdSal.getRpcService(EventSourceService.class); - - if (ess == null) { - throw new IllegalStateException("EventSourceService is not registered."); - } + Preconditions.checkState(ess != null, "EventSourceService is not registered"); ess.joinTopic(jti); }