- final BindingAwareConsumer consumer = new BindingAwareConsumer() {
- @Override
- public void onSessionInitialized(final ConsumerContext session) {
- consumerService = session.getRpcService(OpendaylightTestRoutedRpcService.class);
- }
- };
- LOG.info("Register routeService consumer");
- broker.registerConsumer(consumer);
-
+ OpendaylightTestRoutedRpcService consumerService =
+ rpcProviderRegistry.getRpcService(OpendaylightTestRoutedRpcService.class);