import java.util.concurrent.Future;
import org.junit.Test;
import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext;
import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer;
import org.opendaylight.controller.sal.binding.api.data.DataBrokerService;
import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
*/
@Test
public void test() throws Exception {
- BindingAwareConsumer consumer = new BindingAwareConsumer() {
-
- @Override
- public void onSessionInitialized(final ConsumerContext session) {
- consumerDataService = session.getSALService(DataBrokerService.class);
- }
- };
+ BindingAwareConsumer consumer = session -> consumerDataService = session.getSALService(DataBrokerService.class);
broker.registerConsumer(consumer);
import java.util.List;
import org.junit.Test;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext;
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer;
import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
LOG.info("The registration of the Consumer 1. It retrieves Notification Service "
+ "from MD-SAL and registers OpendaylightTestNotificationListener as notification listener");
- BindingAwareConsumer consumer1 = new BindingAwareConsumer() {
- @Override
- public void onSessionInitialized(ConsumerContext session) {
- NotificationService notificationService = session.getSALService(NotificationService.class);
- assertNotNull(notificationService);
- listener1Reg = notificationService.registerNotificationListener(listener1);
- }
+ BindingAwareConsumer consumer1 = session -> {
+ NotificationService notificationService = session.getSALService(NotificationService.class);
+ assertNotNull(notificationService);
+ listener1Reg = notificationService.registerNotificationListener(listener1);
};
// registerConsumer method calls onSessionInitialized method above
broker.registerConsumer(consumer1);
LOG.info("The registration of the Consumer 2. SalFlowListener is registered "
+ "registered as notification listener.");
- BindingAwareProvider provider = new BindingAwareProvider() {
-
- @Override
- public void onSessionInitiated(ProviderContext session) {
- listener2Reg = session.getSALService(NotificationProviderService.class).registerNotificationListener(
- listener2);
- }
- };
+ BindingAwareProvider provider = session -> listener2Reg = session.getSALService(NotificationProviderService.class).registerNotificationListener(
+ listener2);
// registerConsumer method calls onSessionInitialized method above
broker.registerProvider(provider);
import org.junit.Before;
import org.junit.Test;
import org.mockito.Mockito;
-import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext;
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RoutedRpcRegistration;
import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer;
assertSame(odlRoutedService2, secondReg.getInstance());
assertNotSame(secondReg, firstReg);
- final BindingAwareConsumer consumer = new BindingAwareConsumer() {
- @Override
- public void onSessionInitialized(final ConsumerContext session) {
- consumerService = session.getRpcService(OpendaylightTestRoutedRpcService.class);
- }
- };
+ final BindingAwareConsumer consumer =
+ session -> consumerService = session.getRpcService(OpendaylightTestRoutedRpcService.class);
LOG.info("Register routeService consumer");
broker.registerConsumer(consumer);