+ new GetNotificationsAlarmServiceImpl(converterAlarm, "localhost:8080")
+ .invoke(new GetNotificationsAlarmServiceInputBuilder()
+ .setGroupId("groupId")
+ .setIdConsumer("consumerId")
+ .setConnectionType(ConnectionType.Service)
+ .build());
+ assertNull(result.get().getResult().getNotificationsAlarmService(), "Should be null");
+ }
+
+ @Test
+ void createTapiNotificationSubscriptionServiceTest() throws InterruptedException, ExecutionException {
+ ListenableFuture<RpcResult<CreateNotificationSubscriptionServiceOutput>> result =
+ new CreateNotificationSubscriptionServiceImpl(nbiNotificationsImpl, topicManager)
+ .invoke(NotificationServiceDataUtils.buildNotificationSubscriptionServiceInputBuilder().build());
+ assertNotNull(result.get().getResult().getSubscriptionService().getUuid().toString(),
+ "Should receive UUID for subscription service");
+ }
+
+ @Test
+ void getTapiNotificationsServiceTest() throws InterruptedException, ExecutionException {
+ ListenableFuture<RpcResult<CreateNotificationSubscriptionServiceOutput>> result =
+ new CreateNotificationSubscriptionServiceImpl(nbiNotificationsImpl, topicManager)
+ .invoke(NotificationServiceDataUtils.buildNotificationSubscriptionServiceInputBuilder().build());
+ ListenableFuture<RpcResult<GetNotificationListOutput>> result2 =
+ new GetNotificationListImpl(converterTapi, "localhost:8080", networkTransactionService, topicManager)
+ .invoke(new GetNotificationListInputBuilder()
+ .setTimeRange(null)
+ .setSubscriptionId(result.get().getResult().getSubscriptionService().getUuid())
+ .build());
+ assertNull(result2.get().getResult().getNotification(), "Should be null");