SSCSSI-443: Remove feature toggle BYPASS_NOTIFICATIONS_SERVICE

charts/sscs-tribunals-api/values.aat.template.yaml

@@ -10,6 +10,5 @@ java:
     HANDLE_CCD_CALLBACKMAP_V2: true
     POST_HEARINGS_B_FEATURE: true
     POST_HEARINGS_FEATURE: true
-    BYPASS_NOTIFICATIONS_SERVICE: true
     INFECTED_BLOOD_COMPENSATION_ENABLED: true
     SUBMIT_APPEAL_SERVICE_V2_ENABLED: true

charts/sscs-tribunals-api/values.hearings.preview.template.yaml

@@ -41,7 +41,6 @@ java:
     DELETED_REDACTED_DOC_ENABLED: true
     CITIZEN_LOGIN_SERVICE_V2: true
     ADD_LINK_TO_OTHER_ASSOCIATED_CASES_V2: true
-    BYPASS_NOTIFICATIONS_SERVICE: true
     HANDLE_CCD_CALLBACKMAP_V2: true
     TESTING_SUPPORT_ENABLED: true
     SEND_LETTER_SERVICE_ENABLED: "true"

charts/sscs-tribunals-api/values.preview.template.yaml

@@ -39,7 +39,6 @@ java:
     DELETED_REDACTED_DOC_ENABLED: true
     CITIZEN_LOGIN_SERVICE_V2: true
     ADD_LINK_TO_OTHER_ASSOCIATED_CASES_V2: true
-    BYPASS_NOTIFICATIONS_SERVICE: true
     BYPASS_HEARING_API_SERVICE: true
     HANDLE_CCD_CALLBACKMAP_V2: true
     TESTING_SUPPORT_ENABLED: true

src/main/java/uk/gov/hmcts/reform/sscs/service/servicebus/TopicConsumer.java

@@ -28,18 +28,15 @@ public class TopicConsumer {
     private final CallbackDispatcher<SscsCaseData> dispatcher;
     private final SscsCaseCallbackDeserializer sscsDeserializer;
     private final NotificationsMessageProcessor notificationsMessageProcessor;
-    private final boolean isNotificationServiceBypassed;
 
     public TopicConsumer(@Value("${callback.maxRetryAttempts}") Integer maxRetryAttempts,
                          CallbackDispatcher<SscsCaseData> dispatcher,
-                         SscsCaseCallbackDeserializer sscsDeserializer, NotificationsMessageProcessor notificationsMessageProcessor,
-                         @Value("${feature.bypass-notifications-service.enabled:false}") boolean isNotificationServiceBypassed) {
+                         SscsCaseCallbackDeserializer sscsDeserializer, NotificationsMessageProcessor notificationsMessageProcessor) {
         this.maxRetryAttempts = maxRetryAttempts;
         //noinspection unchecked
         this.dispatcher = dispatcher;
         this.sscsDeserializer = sscsDeserializer;
         this.notificationsMessageProcessor = notificationsMessageProcessor;
-        this.isNotificationServiceBypassed = isNotificationServiceBypassed;
     }
 
 
@@ -52,12 +49,7 @@ public TopicConsumer(@Value("${callback.maxRetryAttempts}") Integer maxRetryAtte
     public void onMessage(String message, @Header(JmsHeaders.MESSAGE_ID) String messageId) {
         log.info("Message Id {} received from the service bus", messageId);
         processEvidenceShareMessageWithRetry(message, 1, messageId);
-
-        log.info("Determining if notification service should be bypassed {} ", isNotificationServiceBypassed ? "Yes" : "No");
-        if (isNotificationServiceBypassed) {
-            log.info("Bypassing notification service for message id {}", messageId);
-            notificationsMessageProcessor.processMessage(message, messageId);
-        }
+        notificationsMessageProcessor.processMessage(message, messageId);
     }
 
     private void processEvidenceShareMessageWithRetry(String message, int retry, String messageId) {

src/main/resources/config/application.yaml

@@ -283,8 +283,6 @@ feature:
         enabled: ${SCOTTISH_PO_BOX_ENABLED:false}
     urgent-hearing:
         enabled: ${URGENT_HEARING_ENABLED:false}
-    bypass-notifications-service:
-        enabled: ${BYPASS_NOTIFICATIONS_SERVICE:false}
     handle-ccd-callbackMap-v2:
         enabled: ${HANDLE_CCD_CALLBACKMAP_V2:false}
     submit-appeal-service-v2:
@@ -2033,14 +2031,12 @@ spring:
             accept-case-insensitive-enums: true
             accept-case-insensitive-properties: true
 job.scheduler:
-    autoStart: ${BYPASS_NOTIFICATIONS_SERVICE:false}
     retryPolicy:
         maxNumberOfJobExecutions: 2
         delayBetweenAttemptsInMs: 1000
     quartzProperties:
         org.quartz:
             scheduler:
-                autoStartup: ${BYPASS_NOTIFICATIONS_SERVICE:false}
                 instanceId: AUTO
                 idleWaitTime: ${JOB_SCHEDULER_POLL_INTERVAL:10000}
             dataSource:

src/test/java/uk/gov/hmcts/reform/sscs/service/servicebus/TopicConsumerTest.java

@@ -42,7 +42,7 @@ public class TopicConsumerTest {
 
     @Before
     public void setup() {
-        topicConsumer = new TopicConsumer(RETRY_THREE_TIMES, dispatcher, deserializer, notificationsMessageProcessor, false);
+        topicConsumer = new TopicConsumer(RETRY_THREE_TIMES, dispatcher, deserializer, notificationsMessageProcessor);
     }
 
     @Test
@@ -134,7 +134,7 @@ public void handleValidRequest() {
 
     @Test
     public void shouldProcessMessageForNotifications() {
-        topicConsumer = new TopicConsumer(RETRY_THREE_TIMES, dispatcher, deserializer, notificationsMessageProcessor, true);
+        topicConsumer = new TopicConsumer(RETRY_THREE_TIMES, dispatcher, deserializer, notificationsMessageProcessor);
         topicConsumer.onMessage(MESSAGE, "1");
         verify(notificationsMessageProcessor).processMessage(MESSAGE, "1");
     }