Cookie generator not work
This commit is contained in:
@@ -31,7 +31,7 @@ class CookiesPublisher:
|
||||
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(self.to_queue))
|
||||
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
|
||||
))
|
||||
|
||||
Reference in New Issue
Block a user