Skip to content

Commit 27f151d

Browse files
lmarinibodom0015
andauthored
Update app/services/EventSinkService.scala
Co-authored-by: Mike Lambert <[email protected]>
1 parent d0b84db commit 27f151d

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

app/services/EventSinkService.scala

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,11 @@ class EventSinkService {
3333
// Inject timestamp before logging the event
3434
val event = message.as[JsObject] + ("created" -> Json.toJson(java.util.Date.from(Instant.now())))
3535
Logger.info("Submitting message to event sink exchange: " + Json.stringify(event))
36-
messageService.submit(exchangeName, queueName, event, "fanout")
36+
try {
37+
messageService.submit(exchangeName, queueName, event, "fanout")
38+
} catch {
39+
case e: Throwable => { Logger.error("Failed to submit event sink message", e) }
40+
}
3741
}
3842

3943
/** Log an event when user signs up */

0 commit comments

Comments
 (0)