in amazon-chime-sdk/src/main/java/com/amazonaws/services/chime/sdk/meetings/ingestion/DefaultEventSender.kt [34:60]
override suspend fun sendRecord(record: IngestionRecord): Boolean {
return try {
val body = gson.toJson(record)
val response = HttpUtils.post(
eventUrl,
body,
DefaultBackOffRetry(
ingestionConfiguration.retryCountLimit,
retryableStatusCodes = retryableCodeSet
),
logger,
mapOf(
AUTHORIZATION_HEADER to "$BEARER ${ingestionConfiguration.clientConfiguration.eventClientJoinToken}"
)
)
if (response.httpException != null) {
logger.error(TAG, "Failed to send ingestion record: $response")
false
} else { true }
} catch (err: Exception) {
logger.error(
TAG,
"Unable to send record ${err.localizedMessage}"
)
false
}
}