notification_service_state_2.bal

WeatherReport weatherReport = getWeatherReport(location);
if weatherReport is error {
    log:printWarn(string `Error occurred while retrieving weather-report: ${weatherReport.message()}`, stackTrace = weatherReport.stackTrace());
    continue;
}

foreach var [newsReceiverId, clientEp] in newsDispatchClients.entries() {
    websubhub:ContentDistributionSuccess|error response = clientEp->notifyContentDistribution({
        contentType: mime:APPLICATION_JSON,
        content: {
            "weather-report": weatherReport.toJson()
        }
    });
    
    if response is websubhub:SubscriptionDeletedError {
        log:printWarn("News receiver responded with subscription-delete response, hence removing", id = newsReceiverId);
        removeNewsReceiver(newsReceiverId);
    }
}