From 217efe3c20ef5ab5fbc3f9de05368b47d146ab26 Mon Sep 17 00:00:00 2001
From: Daniel Tomlinson <dtomlinson@panaetius.co.uk>
Date: Sun, 6 Oct 2019 03:16:27 +0100
Subject: [PATCH] updating sendToSQS.py

---
 .../pullTrafficInfo.cpython-37.pyc            | Bin 4973 -> 4973 bytes
 slack-bot/sendToSQS.py                        |  22 ++++++++++--------
 2 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc b/slack-bot/__pycache__/pullTrafficInfo.cpython-37.pyc
index 3a1df30139dba876ec2eff945946b98fc94c0f8a..a8a99081727e4e9245da21bfbc0ca21881d052d0 100644
GIT binary patch
delta 19
ZcmaE>_EwF{iI<m)0SFR(HgY8k0{}DC1a$xa

delta 19
ZcmaE>_EwF{iI<m)0SLI&HgY8k0{}4-1Ni^|

diff --git a/slack-bot/sendToSQS.py b/slack-bot/sendToSQS.py
index 0827c14..7bd9367 100644
--- a/slack-bot/sendToSQS.py
+++ b/slack-bot/sendToSQS.py
@@ -38,16 +38,18 @@ for item in inst.output:
     message = sqs.send_message(QueueUrl=queueURL,
                                MessageBody=encoded,
                                MessageGroupId=f'slack-bot-{motorway}')
-    response = sqs.receive_message(QueueUrl=queueURL,
-                                   MaxNumberOfMessages=5)
-    if 'Messages' in response:
-        for message in response['Messages']:
-            # print(message['Body'])
-            # break
-            decoded = base64.b64decode(message['Body'].encode())
-            print(decoded.decode())
-    else:
-        print('Queue is empty')
     # print(encoded)
     # print(encoded.encode())
     # print(base64.b64decode(encoded.encode()).decode())
+
+
+response = sqs.receive_message(QueueUrl=queueURL,
+                               MaxNumberOfMessages=4)
+if 'Messages' in response:
+    for message in response['Messages']:
+        # print(message['Body'])
+        # break
+        decoded = base64.b64decode(message['Body'].encode())
+        print(decoded.decode())
+else:
+    print('Queue is empty')