File tree Expand file tree Collapse file tree
football/src/main/scala/com/gu/mobile/notifications/football/lib Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -44,14 +44,16 @@ class LiveActivityPusher extends Logging {
4444 " Eventbus pusher: Try to push events to eventbus, number of events: " + matchDataList.size
4545 )
4646 matchDataList.map(matchData => {
47+ println(s " Eventbus pusher: Processing event for match with article id ${matchData.articleId}" )
4748
4849 val jsonDetail = Json .toJson(matchData).toString()
4950 if (jsonDetail.isEmpty || jsonDetail == " {}" ) {
50- println(s " Eventbus pusher: Skipping empty event for ${matchData.matchDay.id}" )
51+ println(
52+ s " Eventbus pusher: Skipping empty event for ${matchData.matchDay.id}"
53+ )
5154 } else {
5255
5356 val result = Try {
54- println(s " Eventbus pusher: Try publishing event for match ${matchData.matchDay.id}" )
5557 val entry = PutEventsRequestEntry
5658 .builder()
5759 .source(" football-lambda" )
@@ -67,12 +69,12 @@ class LiveActivityPusher extends Logging {
6769
6870 val response = eventBridgeClient.putEvents(request)
6971 println(
70- s " Event published. Failed entry count: ${response.failedEntryCount()}"
72+ s " Eventbus pusher: Event published. Failed entry count: ${response.failedEntryCount()}"
7173 )
7274 }
7375
7476 result.failed.foreach(e =>
75- println(s " Failed to publish event: ${e.getMessage}" )
77+ println(s " Eventbus pusher: Failed to publish event: ${e.getMessage}" )
7678 )
7779
7880 }
You can’t perform that action at this time.
0 commit comments