diff --git a/main.py b/main.py index 8c322c5..39d7e56 100644 --- a/main.py +++ b/main.py @@ -3,7 +3,7 @@ from time import sleep, time from multiprocessing import Process, Queue import source.vqe as vqe -import source.mqtt as mqtt +import project.source.archive.mqtt as mqtt if __name__ == "__main__": diff --git a/source/mqtt.py b/source/archive/mqtt.py similarity index 93% rename from source/mqtt.py rename to source/archive/mqtt.py index 47375ae..244e658 100644 --- a/source/mqtt.py +++ b/source/archive/mqtt.py @@ -2,7 +2,7 @@ import paho.mqtt.client as paho import paho.mqtt.enums as paho_enums class vqeMqttBroker: - def __init__(self, broker_address, broker_port, username="", password="", use_tls=True, max_connection_attempts=30): + def __init__(self, broker_address, broker_port, username="correct", password="any", use_tls=True, max_connection_attempts=30): self.server = broker_address self.port = broker_port self.client = paho.Client(callback_api_version=paho.CallbackAPIVersion.VERSION2, client_id="my_python_client", reconnect_on_failure=True) diff --git a/source/rabbitmq_test.py b/source/rabbitmq_test.py new file mode 100644 index 0000000..bb570ca --- /dev/null +++ b/source/rabbitmq_test.py @@ -0,0 +1,20 @@ +import pika +import ssl + +print + +context = ssl.create_default_context() +context.verify_mode = ssl.CERT_REQUIRED + +ssl_options= pika.SSLOptions(context=context, server_hostname="rabbitmq.deowl.ru") + +credential = pika.PlainCredentials("admin", "admin") + +try: + connection = pika.BlockingConnection(pika.ConnectionParameters('rabbitmq.deowl.ru', virtual_host='/', port=5671, ssl_options=ssl_options, credentials=credential)) + channel = connection.channel() + print("good") +except pika.exceptions.AMQPConnectionError as e: + print(f"Connection error: {e}") +except Exception as e: + print(f"An unexpected error occurred: {e}") \ No newline at end of file