fix wrong proxy list
This commit is contained in:
@@ -98,13 +98,14 @@ class AppointmentRequestSendor(threading.Thread):
|
|||||||
|
|
||||||
def on_message(self, ch, method, properties, body):
|
def on_message(self, ch, method, properties, body):
|
||||||
print(f" [x] Received {body}")
|
print(f" [x] Received {body}")
|
||||||
print("message count in queue is {}".format(self.cookiesPublisher.message_count()))
|
_message_count = self.cookiesPublisher.message_count()
|
||||||
|
print("message count in queue is {}".format(_message_count))
|
||||||
sender = Sender(body.decode("UTF-8"), cookiesPublisher=self.cookiesPublisher,
|
sender = Sender(body.decode("UTF-8"), cookiesPublisher=self.cookiesPublisher,
|
||||||
proxy_to_use=random.choice(PROXY_LIST_DE))
|
proxy_to_use=random.choice(self.proxy_to_use_list))
|
||||||
self.contact_list = filter_contacts(self.contact_list)
|
self.contact_list = filter_contacts(self.contact_list)
|
||||||
# remove already booked contacts
|
# remove already booked contacts
|
||||||
random.shuffle(self.contact_list)
|
random.shuffle(self.contact_list)
|
||||||
if len(self.contact_list) > 0 and is_open():
|
if len(self.contact_list) > 0 and is_open() and _message_count > 40:
|
||||||
captchaResultGetter = CaptchaResultGetter()
|
captchaResultGetter = CaptchaResultGetter()
|
||||||
print("contact number is {}".format(len(self.contact_list)))
|
print("contact number is {}".format(len(self.contact_list)))
|
||||||
self.contact_list = filter_contacts(self.contact_list)
|
self.contact_list = filter_contacts(self.contact_list)
|
||||||
|
|||||||
@@ -135,7 +135,7 @@ def validate_with_FR_ip():
|
|||||||
_fr_proxy_to_use = random.choice(PROXY_LIST_FR)
|
_fr_proxy_to_use = random.choice(PROXY_LIST_FR)
|
||||||
receiver = LinkValidator(link_to_validate_list=_link_list_to_click, cookiesPublisher=cookiesPublisher,
|
receiver = LinkValidator(link_to_validate_list=_link_list_to_click, cookiesPublisher=cookiesPublisher,
|
||||||
proxy_to_use=_fr_proxy_to_use,
|
proxy_to_use=_fr_proxy_to_use,
|
||||||
queue_to_listen=_queue_name, ip_country="FR", limit=10)
|
queue_to_listen=_queue_name, ip_country="FR", limit=40)
|
||||||
receiver.set_up_connection()
|
receiver.set_up_connection()
|
||||||
receiver.listen_to_queue(receiver.on_message)
|
receiver.listen_to_queue(receiver.on_message)
|
||||||
pass
|
pass
|
||||||
|
|||||||
Reference in New Issue
Block a user