fix(queues): fix nonsensical parse logic for sqs notifications
This commit is contained in:
Родитель
efb8f0d782
Коммит
1c21d6eca1
|
@ -15,7 +15,7 @@ use rusoto_sqs::{
|
||||||
DeleteMessageError, DeleteMessageRequest, Message as SqsMessage, ReceiveMessageError,
|
DeleteMessageError, DeleteMessageRequest, Message as SqsMessage, ReceiveMessageError,
|
||||||
ReceiveMessageRequest, SendMessageError, SendMessageRequest, Sqs, SqsClient,
|
ReceiveMessageRequest, SendMessageError, SendMessageRequest, Sqs, SqsClient,
|
||||||
};
|
};
|
||||||
use serde_json::{self, Error as JsonError, Value as JsonValue};
|
use serde_json::{self, Error as JsonError};
|
||||||
|
|
||||||
use self::notification::Notification as SqsNotification;
|
use self::notification::Notification as SqsNotification;
|
||||||
use super::{
|
use super::{
|
||||||
|
@ -59,7 +59,7 @@ impl Queue {
|
||||||
)));
|
)));
|
||||||
}
|
}
|
||||||
|
|
||||||
serde_json::from_value(JsonValue::String(body.clone()))
|
serde_json::from_str(&body)
|
||||||
.map(|notification: SqsNotification| {
|
.map(|notification: SqsNotification| {
|
||||||
println!(
|
println!(
|
||||||
"Successfully parsed SQS message, queue=`{}`, receipt_handle=`{}`, notification_type=`{}`",
|
"Successfully parsed SQS message, queue=`{}`, receipt_handle=`{}`, notification_type=`{}`",
|
||||||
|
|
Загрузка…
Ссылка в новой задаче