- public void getNotificationsServiceEmptyDataTest() throws InterruptedException, ExecutionException {
- ListenableFuture<RpcResult<GetNotificationsServiceOutput>> result =
- nbiNotificationsImpl.getNotificationsService(new GetNotificationsServiceInputBuilder().build());
- assertNull("Should be null", result.get().getResult().getNotificationService());
+ @Test
+ void getNotificationsServiceEmptyDataTest() throws InterruptedException, ExecutionException {
+ ListenableFuture<RpcResult<GetNotificationsProcessServiceOutput>> result =
+ nbiNotificationsImpl.getNotificationsProcessService(
+ new GetNotificationsProcessServiceInputBuilder().build());
+ assertNull(result.get().getResult().getNotificationsProcessService(), "Should be null");
+ }
+
+ @Test
+ void getNotificationsServiceTest() throws InterruptedException, ExecutionException {
+ GetNotificationsProcessServiceInputBuilder builder = new GetNotificationsProcessServiceInputBuilder()
+ .setGroupId("groupId")
+ .setIdConsumer("consumerId")
+ .setConnectionType(ConnectionType.Service);
+ ListenableFuture<RpcResult<GetNotificationsProcessServiceOutput>> result =
+ nbiNotificationsImpl.getNotificationsProcessService(builder.build());
+ assertNull(result.get().getResult().getNotificationsProcessService(), "Should be null");
+ }
+
+ @Test
+ void getNotificationsAlarmServiceTest() throws InterruptedException, ExecutionException {
+ GetNotificationsAlarmServiceInputBuilder builder = new GetNotificationsAlarmServiceInputBuilder()
+ .setGroupId("groupId")
+ .setIdConsumer("consumerId")
+ .setConnectionType(ConnectionType.Service);
+ ListenableFuture<RpcResult<GetNotificationsAlarmServiceOutput>> result =
+ nbiNotificationsImpl.getNotificationsAlarmService(builder.build());
+ assertNull(result.get().getResult().getNotificationsAlarmService(), "Should be null");
+ }
+
+ @Test
+ void createTapiNotificationSubscriptionServiceTest() throws InterruptedException, ExecutionException {
+ CreateNotificationSubscriptionServiceInputBuilder builder
+ = NotificationServiceDataUtils.buildNotificationSubscriptionServiceInputBuilder();
+ ListenableFuture<RpcResult<CreateNotificationSubscriptionServiceOutput>> result =
+ nbiNotificationsImpl.createNotificationSubscriptionService(builder.build());
+ assertNotNull(result.get().getResult().getSubscriptionService().getUuid().toString(),
+ "Should receive UUID for subscription service");