import pika

def sendQuery(result_json, steamid, new_query):
    connection = pika.BlockingConnection(pika.ConnectionParameters(host="23.88.122.57", credentials=pika.PlainCredentials("worker", "Margarethe1!")),)
    channel = connection.channel()

    channel.queue_declare(queue="task_queue", durable=True, auto_delete=False)
    channel.confirm_delivery()

    try:
        channel.basic_publish(
            exchange="task_queue",
            routing_key="task_queue",
            body=str([result_json, steamid, new_query.pk]),
            properties=pika.BasicProperties(
                delivery_mode=pika.DeliveryMode.Persistent,
            ),
            mandatory=True
        )
    except pika.exceptions.UnroutableError:
        print('Message was returned')
    print(f" [x] Sent {result_json}")

    connection.close()