- 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);