X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsamples%2Ftoaster-consumer%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsample%2Fkitchen%2Fimpl%2FKitchenServiceImpl.java;h=306efc5e63dd613b335f935ca168f4bd8a1fd0fa;hb=HEAD;hp=68daabaa91287ee76e19462dc37e8b727350eb4e;hpb=dfc0c67fb640bb370eabb77953c9f625b5dc9adb;p=controller.git diff --git a/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java b/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java index 68daabaa91..b67de11367 100644 --- a/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java +++ b/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java @@ -26,7 +26,7 @@ import org.opendaylight.controller.sample.kitchen.api.KitchenService; import org.opendaylight.controller.sample.kitchen.api.KitchenServiceRuntimeMXBean; import org.opendaylight.mdsal.binding.api.NotificationService; import org.opendaylight.mdsal.binding.api.NotificationService.CompositeListener; -import org.opendaylight.mdsal.binding.api.RpcConsumerRegistry; +import org.opendaylight.mdsal.binding.api.RpcService; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.MakeToast; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.MakeToastInputBuilder; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.MakeToastOutput; @@ -63,10 +63,10 @@ public final class KitchenServiceImpl extends AbstractMXBean implements KitchenS @Inject @Activate - public KitchenServiceImpl(@Reference final RpcConsumerRegistry rpcRegistry, + public KitchenServiceImpl(@Reference final RpcService rpcService, @Reference final NotificationService notifService) { super("KitchenService", "toaster-consumer", null); - makeToast = rpcRegistry.getRpc(MakeToast.class); + makeToast = rpcService.getRpc(MakeToast.class); reg = notifService.registerCompositeListener(new CompositeListener(Set.of( new CompositeListener.Component<>(ToasterOutOfBread.class, notification -> { LOG.info("ToasterOutOfBread notification");