PI-1630 listen for event type for inner message (#2547)

ministryofjustice · Nov 8, 2023 · 63f5cce · 63f5cce
1 parent 1b7afda
commit 63f5cce
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/projects/opd-and-delius/src/dev/resources/messages/opd-assessment-new.json b/projects/opd-and-delius/src/dev/resources/messages/opd-assessment-new.json
@@ -6,7 +6,7 @@
   "MessageAttributes": {
     "eventType": {
       "Type": "String",
-      "Value": "opd.produced"
+      "Value": "risk-assessment.scores.determined"
     }
   }
 }
diff --git a/projects/opd-and-delius/src/dev/resources/messages/opd-assessment-update.json b/projects/opd-and-delius/src/dev/resources/messages/opd-assessment-update.json
@@ -7,7 +7,7 @@
   "MessageAttributes": {
     "eventType": {
       "Type": "String",
-      "Value": "opd.produced"
+      "Value": "risk-assessment.scores.determined"
     }
   }
 }
diff --git a/projects/opd-and-delius/src/main/kotlin/uk/gov/justice/digital/hmpps/messaging/Handler.kt b/projects/opd-and-delius/src/main/kotlin/uk/gov/justice/digital/hmpps/messaging/Handler.kt
@@ -12,6 +12,7 @@ import uk.gov.justice.digital.hmpps.telemetry.TelemetryService
 import java.time.ZonedDateTime
 
 const val FeatureFlag = "opd-assessment-processing"
+const val OpdProduced = "opd.produced"
 
 @Component
 class Handler(
@@ -21,6 +22,7 @@ class Handler(
     private val featureFlags: FeatureFlags
 ) : NotificationHandler<HmppsDomainEvent> {
     override fun handle(notification: Notification<HmppsDomainEvent>) {
+        if (notification.message.eventType != OpdProduced) return
         val opdAssessment = notification.message.opdAssessment()
         if (!featureFlags.enabled(FeatureFlag)) {
             telemetryService.trackEvent("OpdAssessmentIgnored", opdAssessment.telemetryProperties())