41 lines
1.5 KiB
Python
41 lines
1.5 KiB
Python
import pika
|
|
|
|
QUEUE_HOST = "appointment.lpaconsulting.fr"
|
|
REQUEST_DATA_QUEUE = 'REQUEST_DATA'
|
|
# REQUEST_DATA_QUEUE_TEST = 'REQUEST_DATA_TEST'
|
|
REQUEST_DATA_QUEUE_TEST = 'REQUEST_DATA_TEST'
|
|
TEST_QUEUE = 'TEST_QUEUE'
|
|
SHARED_OBJECT = 'SHARED_OBJECT'
|
|
MORNING_DATA_CACHE = 'MORNING_DATA_CACHE'
|
|
MORNING_DATA_CACHE_2 = 'MORNING_DATA_CACHE_2'
|
|
MORNING_DATA_CACHE_BAK = 'MORNING_DATA_CACHE_BAK'
|
|
REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE'
|
|
REQUEST_DATA_OBJECT = 'REQUEST_DATA_OBJECT'
|
|
REGISTER_QUEUE = 'REGISTER_QUEUE'
|
|
RES_PROXY_DATA = 'RES_PROXY_DATA'
|
|
credentials = pika.PlainCredentials('appointment', 'ZyuhJZ2xEYWhElhpJjy7YEpZGZwNYJz2fHIu')
|
|
|
|
|
|
class CookiesPublisher:
|
|
|
|
def __init__(self, queue_name=REQUEST_DATA_QUEUE):
|
|
self.connection = None
|
|
self.channel = None
|
|
self.queue_method = None
|
|
self.to_queue = queue_name
|
|
|
|
def set_up_connection(self):
|
|
self.connection = pika.BlockingConnection(
|
|
pika.ConnectionParameters(host=QUEUE_HOST, port=5672, credentials=credentials))
|
|
self.channel = self.connection.channel()
|
|
self.queue_method = self.channel.queue_declare(queue=self.to_queue, durable=True)
|
|
|
|
def publish_body(self, body: str):
|
|
print("will push to queue {}".format(body))
|
|
self.channel.basic_publish(exchange='', routing_key=self.to_queue, body=body, properties=pika.BasicProperties(
|
|
delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE
|
|
))
|
|
|
|
def message_count(self):
|
|
return self.channel.queue_declare(queue=self.to_queue, durable=True).method.message_count
|