From 5b21b35f050c8b90cc8fdd4fa03ab28871ee6d36 Mon Sep 17 00:00:00 2001
From: Lei PAN <panleicim@gmail.com>
Date: Fri, 5 Jan 2024 17:01:16 +0100
Subject: [PATCH] add message queue support

---
 queue_message/__init__.py                     |   0
 .../__pycache__/__init__.cpython-39.pyc       | Bin 0 -> 162 bytes
 .../__pycache__/receiver.cpython-39.pyc       | Bin 0 -> 1243 bytes
 queue_message/receiver.py                     |  47 ++++++++++++++++++
 4 files changed, 47 insertions(+)
 create mode 100644 queue_message/__init__.py
 create mode 100644 queue_message/__pycache__/__init__.cpython-39.pyc
 create mode 100644 queue_message/__pycache__/receiver.cpython-39.pyc
 create mode 100644 queue_message/receiver.py

diff --git a/queue_message/__init__.py b/queue_message/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/queue_message/__pycache__/__init__.cpython-39.pyc b/queue_message/__pycache__/__init__.cpython-39.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..d97976019a27d78b14546657697985662f12ab0c
GIT binary patch
literal 162
zcmYe~<>g`kg46obQ$h4&5P=LBfgA@QE@lA|DGb33nv8xc8Hzx{2;!H!erR!OQL%nO
zVqQ*aroKyla%paAUP-Zjd45rLaY15os(xZYL4Ial2}n4;D7COOwYWqdNS3DR$H!;p
bWtPOp>lIYq;;_lhPbtkwwF6o38HgDGRG}$1

literal 0
HcmV?d00001

diff --git a/queue_message/__pycache__/receiver.cpython-39.pyc b/queue_message/__pycache__/receiver.cpython-39.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..7143b98ec95564fbfb43c02c34dd403c78a8739e
GIT binary patch
literal 1243
zcmZuxJ#!N=5S8xBhx17S48u@TaE(2ahK6B)U=mU|K$2miMk7v2e98IlkaR#i>7Y$R
zLu;4$GyH&SsZ!I?!0sJRJb-4jw~|(?eebO;78cqB#+Pqj)eoPL@3@#99xNWiG#xOK
zNSYExq{FCmnWM<qm7eq`4)ZpM3}ovwk*!Y-^CjIOQFsA&NPl!!6h)q7cBnGjNedC@
znJH77WQUyt&E{YCUhVaEcKNd>yHBdQnOJs@os@$uw)U~N|7Orj2gTOW$%Fk~!8X{3
z{{Gfz?O^jo8RH|f!-2(PnC2cBMW9r|97(0~nJ`yE!SIEmWdL7awy@ADe63=YyjMD=
zaA`Ww$875`%`zBCP6=-;WQCiwA30SU0A(t+NuE`$cpzYrp3}-RDm^$SI)sZqx4U~r
zY11u4ma3%tERRd1!*oC7`q%&`syl<6YxS;F#&*G$iVu}B;!t(<pCUWONfmOQWQpZ`
z9*aYn2o31y`V>fKdj1ch7KGM_?t^2=m|Ak=SXWZ(N$1R+P{8P)k|Tc{Ob~BSBX#@9
z{ab`YZsiSfV=J%7wXNo2tt8+`L~5cIY$nHotvpTh_!#6}zvPA8xbj~LEr!Yh8&w;W
z-|O+s?VVk{0M%&3p`j0n4$vTVjkyM1b=@e-%Yt9=jiMNgBGjXczXE4;=aPVbf@9Qj
zI?%_5Y9_F`0WmqE*e7R{HY;SsJ*Cn+bDN#9Hz5@C2j%_#1-3^-*<zv9fwJ)c>MAq)
z94PW@-B>6}n{yE#v(-GCs>oxJrf*?0@@u5*+FN0gn7_*nTWDOsXP`Z*mD!&LueoAN
z#tLnb0tf+)BS)j4RX9!iH)%_0VywzIR8m)U6QT{WOXwn9p`+WEg#8uRj{@wn48-ER
zYI8o!WtpNs&moman-h(HAR2|xn0n^<T0Im_yI|&E*6)Ti^g_Shivqof=Syf-!La3*
hsYtT*tFCJL0u%f%a}_>ps(OSGbti<b2fZ-w{s#9+I!*up

literal 0
HcmV?d00001

diff --git a/queue_message/receiver.py b/queue_message/receiver.py
new file mode 100644
index 0000000..a9f7bf0
--- /dev/null
+++ b/queue_message/receiver.py
@@ -0,0 +1,47 @@
+
+
+import pika
+
+
+QUEUE_HOST = "appointment.lpaconsulting.fr"
+REQUEST_DATA_QUEUE = 'REQUEST_DATA'
+credentials = pika.PlainCredentials('appointment', 'ZyuhJZ2xEYWhElhpJjy7YEpZGZwNYJz2fHIu')
+
+
+class Receiver:
+    def __init__(self):
+        self.connection = None
+        self.channel = None
+
+    def set_up_connection(self):
+        self.connection = pika.BlockingConnection(
+            pika.ConnectionParameters(host=QUEUE_HOST, port=5672, credentials=credentials))
+        self.channel = self.connection.channel()
+
+    def listen_to_queue(self, callback):
+        self.channel.basic_qos(prefetch_count=1)
+        self.channel.basic_consume(queue=REQUEST_DATA_QUEUE, auto_ack=False, on_message_callback=callback)
+        self.channel.start_consuming()
+
+
+# def on_message(ch, method, properties, body):
+#     print(f" [x] Received {body}")
+#     sender = Sender(str(body))
+#     contact_list = read_contacts('/Users/panlei/Desktop/yahoo_aol_valid_26-1.xlsx')
+#     sub_contact_list = contact_list[200:300]
+#     for con in sub_contact_list:
+#         if not is_already_sent(con):
+#             time.sleep(random.randint(2, 10))
+#             can_continue = sender.send_request(HERMES_REGISTER, con)
+#             if not can_continue:
+#                 print("cannot continue")
+#                 break
+#         else:
+#             print(con.mail + "--> skip")
+#         print(con.mail)
+#
+#
+# if __name__ == '__main__':
+#     receiver = Receiver()
+#     receiver.set_up_connection()
+#     receiver.listen_to_queue(on_message)