From 1c21d6eca1b41a02141852fe7d1122d5fb31a7a4 Mon Sep 17 00:00:00 2001 From: Phil Booth Date: Thu, 21 Jun 2018 10:11:47 +0100 Subject: [PATCH] fix(queues): fix nonsensical parse logic for sqs notifications --- src/queues/sqs/mod.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/queues/sqs/mod.rs b/src/queues/sqs/mod.rs index 29537e2..6f74bdf 100644 --- a/src/queues/sqs/mod.rs +++ b/src/queues/sqs/mod.rs @@ -15,7 +15,7 @@ use rusoto_sqs::{ DeleteMessageError, DeleteMessageRequest, Message as SqsMessage, ReceiveMessageError, 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 super::{ @@ -59,7 +59,7 @@ impl Queue { ))); } - serde_json::from_value(JsonValue::String(body.clone())) + serde_json::from_str(&body) .map(|notification: SqsNotification| { println!( "Successfully parsed SQS message, queue=`{}`, receipt_handle=`{}`, notification_type=`{}`",