From 936b43cd8c446107e1f97972ad25b85f89b280c9 Mon Sep 17 00:00:00 2001 From: Peter Kotyczka Date: Wed, 7 Feb 2024 01:07:46 +0100 Subject: [PATCH] queue in editor integrated - not yet fully functioning --- README.MD | 7 +- app/__pycache__/config.cpython-311.pyc | Bin 0 -> 226 bytes app/address.py | 66 ++++++++++++++ app/basic.py | 47 ++++++++++ app/config.py | 2 + app/dice.py | 17 ++++ app/edit.py | 86 ++++++++++++++++++ app/queue_consumer.py | 22 +++++ app/queue_producer.py | 21 +++++ app/temp.py | 41 +++++++++ demo/api_client/basic.py | 10 ++ demo/db.sqlite3 | Bin 131072 -> 131072 bytes demo/demo/__pycache__/urls.cpython-311.pyc | Bin 1287 -> 1377 bytes demo/demo/urls.py | 2 + .../__pycache__/models.cpython-311.pyc | Bin 237 -> 827 bytes .../__pycache__/urls.cpython-311.pyc | Bin 479 -> 552 bytes .../__pycache__/views.cpython-311.pyc | Bin 683 -> 1438 bytes demo/migration/models.py | 4 + demo/migration/urls.py | 1 + demo/migration/views.py | 19 +++- docker-compose-queue.yml | 22 +++++ docker-compose.yml | 1 + queue/data/.erlang.cookie | 1 + .../mnesia/rabbit@5c60bc6971d3-feature_flags | 17 ++++ .../rabbit@5c60bc6971d3/DECISION_TAB.LOG | Bin 0 -> 161 bytes .../mnesia/rabbit@5c60bc6971d3/LATEST.LOG | Bin 0 -> 2672 bytes .../rabbit@5c60bc6971d3/cluster_nodes.config | 1 + .../rabbit@5c60bc6971d3/00000001.wal | 1 + .../rabbit@5c60bc6971d3/meta.dets | Bin 0 -> 5464 bytes .../rabbit@5c60bc6971d3/names.dets | Bin 0 -> 5464 bytes .../vhosts/628WB79CIFDYO9LJI6DKMI09L/.config | 2 + .../vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost | 1 + .../msg_store_persistent/0.rdq | 0 .../msg_store_persistent/clean.dot | 2 + .../msg_store_persistent/file_summary.ets | Bin 0 -> 619 bytes .../msg_store_persistent/msg_store_index.ets | Bin 0 -> 545 bytes .../msg_store_transient/0.rdq | 0 .../msg_store_transient/clean.dot | 2 + .../msg_store_transient/file_summary.ets | Bin 0 -> 619 bytes .../msg_store_transient/msg_store_index.ets | Bin 0 -> 545 bytes .../5BY898XLEGEBFE6E2YXLPN9EB/.queue_name | 2 + .../5BY898XLEGEBFE6E2YXLPN9EB/journal.jif | 0 .../5DFCY53MTYI7QMR2T268HJ0JX/.queue_name | 2 + .../5DFCY53MTYI7QMR2T268HJ0JX/journal.jif | 0 .../628WB79CIFDYO9LJI6DKMI09L/recovery.dets | Bin 0 -> 6496 bytes .../mnesia/rabbit@5c60bc6971d3/node-type.txt | 1 + .../nodes_running_at_shutdown | 1 + .../quorum/rabbit@5c60bc6971d3/00000001.wal | 1 + .../quorum/rabbit@5c60bc6971d3/meta.dets | Bin 0 -> 5464 bytes .../quorum/rabbit@5c60bc6971d3/names.dets | Bin 0 -> 5464 bytes .../rabbit_durable_exchange.DCD | Bin 0 -> 1665 bytes .../rabbit_durable_exchange.DCL | Bin 0 -> 514 bytes .../rabbit_durable_queue.DCD | 1 + .../rabbit_durable_queue.DCL | Bin 0 -> 506 bytes .../rabbit_durable_route.DCD | 1 + .../rabbit_runtime_parameters.DCD | Bin 0 -> 199 bytes .../mnesia/rabbit@5c60bc6971d3/rabbit_serial | 1 + .../rabbit_topic_permission.DCD | 1 + .../rabbit@5c60bc6971d3/rabbit_user.DCD | 1 + .../rabbit@5c60bc6971d3/rabbit_user.DCL | Bin 0 -> 433 bytes .../rabbit_user_permission.DCD | 1 + .../rabbit_user_permission.DCL | Bin 0 -> 266 bytes .../rabbit@5c60bc6971d3/rabbit_vhost.DCD | 1 + .../rabbit@5c60bc6971d3/rabbit_vhost.DCL | Bin 0 -> 209 bytes .../mnesia/rabbit@5c60bc6971d3/schema.DAT | Bin 0 -> 27322 bytes 65 files changed, 404 insertions(+), 5 deletions(-) create mode 100644 app/__pycache__/config.cpython-311.pyc create mode 100644 app/address.py create mode 100644 app/basic.py create mode 100644 app/config.py create mode 100644 app/dice.py create mode 100644 app/edit.py create mode 100644 app/queue_consumer.py create mode 100755 app/queue_producer.py create mode 100644 app/temp.py create mode 100644 demo/api_client/basic.py create mode 100644 docker-compose-queue.yml create mode 100644 queue/data/.erlang.cookie create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3-feature_flags create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/DECISION_TAB.LOG create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/LATEST.LOG create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/cluster_nodes.config create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/00000001.wal create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/meta.dets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/names.dets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/.config create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/0.rdq create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/clean.dot create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/file_summary.ets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/msg_store_index.ets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/0.rdq create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/clean.dot create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/file_summary.ets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/msg_store_index.ets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/.queue_name create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/journal.jif create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5DFCY53MTYI7QMR2T268HJ0JX/.queue_name create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5DFCY53MTYI7QMR2T268HJ0JX/journal.jif create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/recovery.dets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/node-type.txt create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/nodes_running_at_shutdown create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/00000001.wal create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/meta.dets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/names.dets create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_exchange.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_exchange.DCL create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_queue.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_queue.DCL create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_route.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_runtime_parameters.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_serial create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_topic_permission.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCL create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user_permission.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user_permission.DCL create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCD create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCL create mode 100644 queue/data/mnesia/rabbit@5c60bc6971d3/schema.DAT diff --git a/README.MD b/README.MD index 57086e7..08915ad 100644 --- a/README.MD +++ b/README.MD @@ -12,10 +12,9 @@ django-admin startproject demo ## install an app python3 manage.py startapp migration +python3 manage.py createsuperuser +python3 manage.py migrate + -- Django calling Rest Services ? - -python3 manage.py newproject demo - - python3 manage.py runserver diff --git a/app/__pycache__/config.cpython-311.pyc b/app/__pycache__/config.cpython-311.pyc new file mode 100644 index 0000000000000000000000000000000000000000..d7d75be8f2669feb445fd7da4501d845ed04ad49 GIT binary patch literal 226 zcmZ3^%ge<81nD~ur5XU~#~=<2FhUuh`GAb+3@Hpz3@MCJj44dP44TZh*mDaLQ*tx& zZt)rW=4BaKW_ddmyHzG7`)M-W;wUXnEy_#GO})iYkXT$?o?n!*lHoJRxL@}Ap+LD} z{p|db%H*o-ME#=Fg8bsllKi5~R3y>Ff`VfGl&r+O^n86FTR%BJFD)}&ub}c5hfQvN oN@-52T@feHJdhiUg@MEeW=2NF8{8rd95=Y78#q9)h#e>n0MLv;cK`qY literal 0 HcmV?d00001 diff --git a/app/address.py b/app/address.py new file mode 100644 index 0000000..e8b39da --- /dev/null +++ b/app/address.py @@ -0,0 +1,66 @@ +import tkinter as tk + +# Create a new window with the title "Address Entry Form" +window = tk.Tk() +window.title("Address Entry Form") + +# Create a new frame `frm_form` to contain the Label +# and Entry widgets for entering address information +frm_form = tk.Frame(relief=tk.SUNKEN, borderwidth=3) +# Pack the frame into the window +frm_form.pack() + +# List of field labels +labels = [ + "First Name:", + "Last Name:", + "Address Line 1:", + "Address Line 2:", + "City:", + "State/Province:", + "Postal Code:", + "Country:", +] + +# Loop over the list of field labels +for idx, text in enumerate(labels): + # Create a Label widget with the text from the labels list + label = tk.Label(master=frm_form, text=text) + # Create an Entry widget + entry = tk.Entry(master=frm_form, width=50) + # Use the grid geometry manager to place the Label and + # Entry widgets in the row whose index is idx + label.grid(row=idx, column=0, sticky="e") + entry.grid(row=idx, column=1) + +# Create a new frame `frm_buttons` to contain the +# Submit and Clear buttons. This frame fills the +# whole window in the horizontal direction and has +# 5 pixels of horizontal and vertical padding. +frm_buttons = tk.Frame() +frm_buttons.pack(fill=tk.X, ipadx=5, ipady=5) + +# Create an event handler +def handle_keypress(event): + """Print the character associated to the key pressed""" + print(event.char) + +# Bind keypress event to handle_keypress() +window.bind("", handle_keypress) + +def handle_click(event): + print("Adress was submitted") + +# Create the "Submit" button and pack it to the +# right side of `frm_buttons` +btn_submit = tk.Button(master=frm_buttons, text="Submit") +btn_submit.pack(side=tk.RIGHT, padx=10, ipadx=10) +btn_submit.bind("", handle_click) + +# Create the "Clear" button and pack it to the +# right side of `frm_buttons` +btn_clear = tk.Button(master=frm_buttons, text="Clear") +btn_clear.pack(side=tk.RIGHT, ipadx=10) + +# Start the application +window.mainloop() \ No newline at end of file diff --git a/app/basic.py b/app/basic.py new file mode 100644 index 0000000..799a723 --- /dev/null +++ b/app/basic.py @@ -0,0 +1,47 @@ +import tkinter as tk + +window = tk.Tk() +label = tk.Label( + text="Python rocks!", + foreground="white", # Set the text color to white + background="black" # Set the background color to black +) + +border_effects = { + "flat": tk.FLAT, + "sunken": tk.SUNKEN, + "raised": tk.RAISED, + "groove": tk.GROOVE, + "ridge": tk.RIDGE, +} +for relief_name, relief in border_effects.items(): + frame = tk.Frame(master=window, relief=relief, borderwidth=5) + frame.pack(side=tk.LEFT) + label = tk.Label(master=frame, text=relief_name) + label.pack() + +label.pack() +entry = tk.Entry() +entry.pack() + +name = entry.get() + +frame_a = tk.Frame() + + +label_a = tk.Label(master=frame_a, text="Personalliste") +label_a.pack() + +frame_a.pack() + +text_box = tk.Text() +text_box.pack() + +frame_b = tk.Frame() +label_b = tk.Label(master=frame_b, text="I'm in Frame B") +label_b.pack() +frame_b.pack() + + +window.mainloop() +print(name) \ No newline at end of file diff --git a/app/config.py b/app/config.py new file mode 100644 index 0000000..170ad07 --- /dev/null +++ b/app/config.py @@ -0,0 +1,2 @@ +username = 'mqadmin' +password = '3Mnj29jKBsFybc' \ No newline at end of file diff --git a/app/dice.py b/app/dice.py new file mode 100644 index 0000000..3a67e1c --- /dev/null +++ b/app/dice.py @@ -0,0 +1,17 @@ +import random +import tkinter as tk + +def roll(): + lbl_result["text"] = str(random.randint(1, 6)) + +window = tk.Tk() +window.columnconfigure(0, minsize=150) +window.rowconfigure([0, 1], minsize=50) + +btn_roll = tk.Button(text="Roll", command=roll) +lbl_result = tk.Label() + +btn_roll.grid(row=0, column=0, sticky="nsew") +lbl_result.grid(row=1, column=0) + +window.mainloop() \ No newline at end of file diff --git a/app/edit.py b/app/edit.py new file mode 100644 index 0000000..99baf94 --- /dev/null +++ b/app/edit.py @@ -0,0 +1,86 @@ +import tkinter as tk +import config as conf +import pika + +from tkinter.filedialog import askopenfilename, asksaveasfilename + +def send_queue_message(exchange_name): + credentials= pika.PlainCredentials(username= conf.username, password= conf.password) + connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials)) + channel= connection.channel() + channel.exchange_declare(exchange = exchange_name, durable=True, exchange_type='topic') + channel.queue_declare(queue = 'AllInfo') + channel.queue_bind(exchange = exchange_name, queue='AllInfo', routing_key='All') + message = txt_edit.get("1.0", tk.END) + + channel.basic_publish(exchange = exchange_name, routing_key = 'All', body = message) + channel.close() + +def get_queue_message(exchange_name): + credentials= pika.PlainCredentials(username= conf.username, password= conf.password) + connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials)) + channel = connection.channel() + channel.exchange_declare(exchange_name, durable=True, exchange_type='topic') + txt_edit.delete("1.0", tk.END) + + def callbackFunctionForQueue(ch,method,properties,body): + message = 'Message from Queue Part: ' + body.decode("utf-8") + txt_edit.insert(tk.END, message) + ch.basic_ack(delivery_tag = method.delivery_tag) + + # Display the message parts + channel.basic_consume(queue='AllInfo', on_message_callback=callbackFunctionForQueue, auto_ack=True) + + # Close the channel and the connection + channel.close() + connection.close() + +def open_file(): + """Open a file for editing.""" + filepath = askopenfilename( + filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")] + ) + if not filepath: + return + txt_edit.delete("1.0", tk.END) + with open(filepath, mode="r", encoding="utf-8") as input_file: + text = input_file.read() + txt_edit.insert(tk.END, text) + window.title(f"Simple Text Editor - {filepath}") + +def save_file(): + """Save the current file as a new file.""" + filepath = asksaveasfilename( + defaultextension=".txt", + filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")], + ) + if not filepath: + return + with open(filepath, mode="w", encoding="utf-8") as output_file: + text = txt_edit.get("1.0", tk.END) + output_file.write(text) + window.title(f"Simple Text Editor - {filepath}") + +window = tk.Tk() +window.title("Simple Text Editor") + +window.rowconfigure(0, minsize=800, weight=1) +window.columnconfigure(1, minsize=800, weight=1) +exchange_name = 'simple-editor' + +txt_edit = tk.Text(window) +frm_buttons = tk.Frame(window, relief=tk.RAISED, bd=2) +btn_open = tk.Button(frm_buttons, text="Open", command=open_file) +btn_save = tk.Button(frm_buttons, text="Save As...", command=save_file) +btn_send = tk.Button(frm_buttons, text="Send", command=send_queue_message(exchange_name)) +btn_receive = tk.Button(frm_buttons, text="Receive", command=get_queue_message(exchange_name)) + +btn_open.grid(row=0, column=0, sticky="ew", padx=5, pady=5) +btn_save.grid(row=1, column=0, sticky="ew", padx=5) +btn_send.grid(row=2, column=0, sticky="ew", padx=5, pady=5) +btn_receive.grid(row=3, column=0, sticky="ew", padx=5, pady=5) + +frm_buttons.grid(row=0, column=0, sticky="ns") +txt_edit.grid(row=0, column=1, sticky="nsew") + +window.mainloop() diff --git a/app/queue_consumer.py b/app/queue_consumer.py new file mode 100644 index 0000000..dbd5f62 --- /dev/null +++ b/app/queue_consumer.py @@ -0,0 +1,22 @@ +import pika, time, config +#declaring the credentials needed for connection like host, port, username, password, exchange etc +credentials= pika.PlainCredentials(username= config.username, password= config.password) +connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials)) +channel = connection.channel() +channel.exchange_declare('pydev', durable=True, exchange_type='topic') +#defining callback functions responding to corresponding queue callbacks +def callbackFunctionForQueueA(ch,method,properties,body): + print('Got a message from Queue A: ', body) +def callbackFunctionForQueueB(ch,method,properties,body): + print('Got a message from Queue B: ', body) +def callbackFunctionForQueueC(ch,method,properties,body): + print('Got a message from Queue C: ', body) +#Attaching consumer callback functions to respective queues that we wrote above +channel.basic_consume(queue='A', on_message_callback=callbackFunctionForQueueA, auto_ack=True) +channel.basic_consume(queue='B', on_message_callback=callbackFunctionForQueueB, auto_ack=True) +channel.basic_consume(queue='C', on_message_callback=callbackFunctionForQueueC, auto_ack=True) +#this will be command for starting the consumer session +channel.start_consuming() +##time.sleep(2) +##channel.stop_consuming() +channel.close() \ No newline at end of file diff --git a/app/queue_producer.py b/app/queue_producer.py new file mode 100755 index 0000000..d8c1d2d --- /dev/null +++ b/app/queue_producer.py @@ -0,0 +1,21 @@ +import pika, config +#declaring the credentials needed for connection like host, port, username, password, exchange etc +credentials= pika.PlainCredentials(username= config.username, password= config.password) +connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials)) +channel= connection.channel() +channel.exchange_declare(exchange='pydev', durable=True, exchange_type='topic') +channel.queue_declare(queue= 'A') +channel.queue_bind(exchange='pydev', queue='A', routing_key='A') +channel.queue_declare(queue= 'B') +channel.queue_bind(exchange='pydev', queue='B', routing_key='B') +channel.queue_declare(queue= 'C') +channel.queue_bind(exchange='pydev', queue='C', routing_key='C') +#messaging to queue named C +message_spec= 'Only this channel can see this message' +message_all= 'Welcome to python queue handling...' +channel.basic_publish(exchange='pydev', routing_key='A', body= message_all) +channel.basic_publish(exchange='pydev', routing_key='B', body= message_all) +channel.basic_publish(exchange='pydev', routing_key='C', body= message_all) +channel.basic_publish(exchange='pydev', routing_key='B', body= message_spec) +channel.basic_publish(exchange='pydev', routing_key='C', body= message_spec) +channel.close() \ No newline at end of file diff --git a/app/temp.py b/app/temp.py new file mode 100644 index 0000000..bbe0e96 --- /dev/null +++ b/app/temp.py @@ -0,0 +1,41 @@ +import tkinter as tk + +def fahrenheit_to_celsius(): + """Convert the value for Fahrenheit to Celsius and insert the + result into lbl_result. + """ + fahrenheit = ent_temperature.get() + celsius = (5 / 9) * (float(fahrenheit) - 32) + lbl_result["text"] = f"{round(celsius, 2)} \N{DEGREE CELSIUS}" + +# Set up the window +window = tk.Tk() +window.title("Temperature Converter") +window.resizable(width=False, height=False) + +# Create the Fahrenheit entry frame with an Entry +# widget and label in it +frm_entry = tk.Frame(master=window) +ent_temperature = tk.Entry(master=frm_entry, width=10) +lbl_temp = tk.Label(master=frm_entry, text="\N{DEGREE FAHRENHEIT}") + +# Layout the temperature Entry and Label in frm_entry +# using the .grid() geometry manager +ent_temperature.grid(row=0, column=0, sticky="e") +lbl_temp.grid(row=0, column=1, sticky="w") + +# Create the conversion Button and result display Label +btn_convert = tk.Button( + master=window, + text="\N{RIGHTWARDS BLACK ARROW}", + command=fahrenheit_to_celsius +) +lbl_result = tk.Label(master=window, text="\N{DEGREE CELSIUS}") + +# Set up the layout using the .grid() geometry manager +frm_entry.grid(row=0, column=0, padx=10) +btn_convert.grid(row=0, column=1, pady=10) +lbl_result.grid(row=0, column=2, padx=10) + +# Run the application +window.mainloop() \ No newline at end of file diff --git a/demo/api_client/basic.py b/demo/api_client/basic.py new file mode 100644 index 0000000..8ffd8e3 --- /dev/null +++ b/demo/api_client/basic.py @@ -0,0 +1,10 @@ +import requests + +endpoint = "https://httpbin.org/status/200" +endpoint = "https://httpbin.org/anything" +endpoint = "http://localhost:8000/api" + +get_response = requests.get(endpoint) # HTTP get request +print(get_response.text) + +# REST API -> Web API \ No newline at end of file diff --git a/demo/db.sqlite3 b/demo/db.sqlite3 index feadb866bb7ef7d5e524d3dd14aac3a6c1a90bec..8b6b49d6c9d7c23cfc0a07627c3eeda533553d80 100644 GIT binary patch delta 225 zcmZo@;Am*zm>|t4KT*b+QGR2BojxPy=K1=m25gM{84Uaxn-vY>`0E=*8F?8RZ5cSl zdG$Ft9eE3qvQyHG;)^p9jZDo{%#93yK*hp4G|bDzFeNF)#6Kb;$tf|^q`)mt#ib%A zF)^puB0IdqFDt;wH`p=JBeA?Z#H}QxJinkk-7LpB%Guc{)1)xawji}6wFpc&WapPu zCRb%A>Lq6wsTvrW=o%R58W<}W8d@0{SeY2;nV1@w85?jhFfcIke`f$9_RWF`ulYGS Qn8i84CNwoHYhY{u0Lo54TmS$7 delta 50 zcmV-20L}k^fCzwq2#^~A9+4bF0UohnJ}&_Xv!5?zFtY@Z2M_@Vvk`#r50Ov>qL2`R Ikfx9UaDD9%5C8xG diff --git a/demo/demo/__pycache__/urls.cpython-311.pyc b/demo/demo/__pycache__/urls.cpython-311.pyc index 7e14fb75c7e7f4deb1769723da116250cfcba29d..6562a837d6aab6e3360c4bf9468f705222a2940f 100644 GIT binary patch delta 230 zcmZqYddS7QoR^o20SLZ_>`UD{kyn!Oz(jRJg%rjV)*QB6jwlXB1}277mK3&BrYug7 zIuOX>nwTTa&JL7dP2rf>r)bET%D#+=fnhZeLjYJ0S1JdpXgW(2cM5kfgC@_$QyZDs zH5qSlBo<^&E@Rf_tYQJO^!+q>CNE+3W-4Nz{D!%hOBiSvBM=vFpPb1OAasL4`Seg$ScV>Z=$-P2opmpOA2c$Qx*qE4g|6|CoYg?X9G&G zrm#<(r6|pj%D#+=fnhZeLqIxn6jusoFoP!7#y1<8Ca+{xWA@YJo_vGZd$I;g0hbU^ g6(bNAPn*1mC15fOtDV3Hb{2l725t~65&%j80Hx|4NB{r; diff --git a/demo/demo/urls.py b/demo/demo/urls.py index 1da78b3..ef3987f 100644 --- a/demo/demo/urls.py +++ b/demo/demo/urls.py @@ -17,9 +17,11 @@ Including another URLconf from django.contrib import admin from django.urls import path,include from migration.views import migration_home +from migration.views import api_home urlpatterns = [ path('admin/', admin.site.urls), path('', include("migration.urls")), path('migration/', migration_home), + path('api/', api_home), ] diff --git a/demo/migration/__pycache__/models.cpython-311.pyc b/demo/migration/__pycache__/models.cpython-311.pyc index f2ae9251215e07df167c1cea0055335e7b7bfcec..3189781163d1fc147f2bcee5afb3e9052aa01f24 100644 GIT binary patch literal 827 zcmZ`%&5P4O6rV|&ev#-^rDd-c>IS3-4jyyyvzgg$+DTHA33T_=gNGgj zk9+l0EA1cPP4O>ip@%Xj!BcOQ)yrOVCTWX`zRA42H}Ci6{djNQ8AcHZx%K5E(I5a{ zrLz`oWnA15#yP+MLkc`-K?oGE53uqIV3oj@vQ8MN0F1;=#ZqzR093SvbSsc&y#Ny$ zIjeB;+mtvH?l~a9f*4qe0*KnmtbrJgm4P5P5<3-3OAy($k5#OWGXp_nv>{{V5=?%B z(Qp>$#`(WU7H~n3Eb`o=Fu<|H7G04b*cLt1wJGtN?BuYbaP5d9zs)m#OzGmPfGlL8 z=9|wyZoc^W{C-7E6R_KKS;Vhk;gbvluWTgYz)CMI5BdTujB%nf`q9ocs0G?bG{ zlpITRAXIO&=6b2WH`7Z)b)r|NdUd8(d%JU^+*@cOz+qmto;l+!joN*kipav7r-85vTTf*CZK zUxE~9GTvg#%}+_qDfZK3y2Y82m6(^Fua}Zk#0-?2e2pP(f)d0X Ui)AO@VUps$z#s!eMQlJ30K&x{S^xk5 diff --git a/demo/migration/__pycache__/urls.cpython-311.pyc b/demo/migration/__pycache__/urls.cpython-311.pyc index 540beddd5405d13e5dc1e5ec4c5eab4bf2914a0d..d55537a21ac6ed8478d2603a564dca4985c2bf0a 100644 GIT binary patch delta 171 zcmcc5yn;o2IWI340}ylv?MpoZq#uJgFu)FFeD0g5o~p;hkjj|ClFFRL29rpQv){$76||q0{|{>B+&o> delta 104 zcmZ3%a-Ug!IWI340}y1&?Ms~tq#uJgFu(?7e9oGvp30TZ6vdXp5zL^;IdPXcv!5pW m#Ggi!O&K$|1c1sIfw(w%@^Z##fe)iMh2^{gO@l2t5g!np-w}{$*tOiIFO_Si-6f`rq){8kIsyf z*vKG*4}yjgda(~V^yCuqBl;Ispo16?J>-;|z!#HK->g1rrOjjK&Ac~n-uK%-E$adT z`0ek%=$iyWZxt~Hpkp|_1=|rKh~NhDa0O#^PBappR?$4Yq64iRqDqqJfDMu)hKqm3 z#5}|mlcXM^eEOYI^cqWpQJ+wjPsq&oLWB<}4+Ec5nYqIQe@ske<=OP zDdVMjAa<*Jb*IE=7;skv%%$hJP8jkM*>?P`phTz_l)SO((o>f{q`b?%EJur9b*w_yDnv$s&8SzVM>%)4 z=-$PRV29av9^PNKAJ7m=#c5Sp8^gr;BBb*OHPQC?2JLGu+Sk)aOq@sPk8|gVAZlvU z<=oeOa~WZ@fqd<`wt=2up~KCY#y6Ri4POiLT%m(yB7 zI-#UN-^54YX|V>?0V8OB;0+W~UzbMcFvsK4tWgK1gUd`c@CEh7rq~T>J}vd10Q%>fS%z{m(VBo?4M457f%_*Kv9N};^ z3buk_i=>>;9X7`zTx4MJmw;NRXU)BM(jq;+|bw_Zf`a;f(*fsdg#8V$hFp*EfT?@#Y&XB^8!kEL5%NWJT2x2qkFy%5wF$3Am zEeugCDJ(#eHH9^pL6hwzNc&30TWm$Cc`2zyKo*ZjNlC%P-o%X`bQzibG}$H}Vo~L0 z1F9+lSyjY0`45W}mk^N22*kyKlNDHHY*j8Wpr8*djEoi^7~ljOBcmROi%t}A1I+*c DmZmPO diff --git a/demo/migration/models.py b/demo/migration/models.py index 71a8362..6d7a892 100644 --- a/demo/migration/models.py +++ b/demo/migration/models.py @@ -1,3 +1,7 @@ from django.db import models # Create your models here. +class Product(models.Model): + title = models.CharField(max_length=120) + content= models.TextField(blank=True, null=True) + price = models.DecimalField(max_digits=15,decimal_places=2,default=99.99) \ No newline at end of file diff --git a/demo/migration/urls.py b/demo/migration/urls.py index b5da84d..bc6fcff 100644 --- a/demo/migration/urls.py +++ b/demo/migration/urls.py @@ -4,4 +4,5 @@ from . import views urlpatterns = [ path("", views.index, name= "index"), path("", views.migration_home, name= "migration"), +path("", views.api_home, name= "api"), ] \ No newline at end of file diff --git a/demo/migration/views.py b/demo/migration/views.py index 0b1a732..b8fcc4f 100644 --- a/demo/migration/views.py +++ b/demo/migration/views.py @@ -1,11 +1,28 @@ from django.shortcuts import render -from django.http import HttpResponse +from django.http import HttpResponse, JsonResponse def index(response): return HttpResponse("Welcome to siMed Migration") def migration_home(request): return render(request,'migration.html') + + +def api_home(request,endpoint, params={"message": "Your JSON Repsonse"}): + body = request.body + data = {} + try: + data = json.loads(body) + except: + pass + print(request.GET) + print(data) + data['params'] = dict(request.GET) + data['headers'] = dict(request.headers) + data['content_type'] = request.content_type + return JsonResponse(data) + + ##return JsonResponse() diff --git a/docker-compose-queue.yml b/docker-compose-queue.yml new file mode 100644 index 0000000..3651928 --- /dev/null +++ b/docker-compose-queue.yml @@ -0,0 +1,22 @@ +version: '3' +services: + rabbitmq: + image: rabbitmq:management + container_name: mq + restart: unless-stopped + environment: + - RABBITMQ_DEFAULT_USER=mqadmin + - RABBITMQ_DEFAULT_PASS=3Mnj29jKBsFybc + ports: + # The standard AMQP protocol port + - '5672:5672' + # HTTP management UI + - '15672:15672' + volumes: + - ./queue/data/:/var/lib/rabbitmq/ + - ./queue/log/:/var/log/rabbitmq/ + networks: + - ametiq +networks: + ametiq: + external: true \ No newline at end of file diff --git a/docker-compose.yml b/docker-compose.yml index 033b2de..2ddc835 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -7,6 +7,7 @@ services: context: . ports: - "9000:8000" + - "7070:8080" networks: - ametiq restart: unless-stopped diff --git a/queue/data/.erlang.cookie b/queue/data/.erlang.cookie new file mode 100644 index 0000000..aa71308 --- /dev/null +++ b/queue/data/.erlang.cookie @@ -0,0 +1 @@ +EASVPCBJZKYPFVDBKWIE \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3-feature_flags b/queue/data/mnesia/rabbit@5c60bc6971d3-feature_flags new file mode 100644 index 0000000..5d4247e --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3-feature_flags @@ -0,0 +1,17 @@ +[classic_mirrored_queue_version, + classic_queue_type_delivery_support, + direct_exchange_routing_v2, + drop_unroutable_metric, + empty_basic_get_metric, + feature_flags_v2, + implicit_default_bindings, + listener_records_in_ets, + maintenance_mode_status, + quorum_queue, + restart_streams, + stream_queue, + stream_sac_coordinator_unblock_group, + stream_single_active_consumer, + tracking_records_in_ets, + user_limits, + virtual_host_metadata]. diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/DECISION_TAB.LOG b/queue/data/mnesia/rabbit@5c60bc6971d3/DECISION_TAB.LOG new file mode 100644 index 0000000000000000000000000000000000000000..e15bab4b77a0761e8d1ada14bd0f19a3837908c4 GIT binary patch literal 161 zcmX}kF%E(-7>3~wN(hQh-h%)t#!YvfaU*U2##S0g+U^eC#LajtFCvMF%e%bE6U8i% zmvauF747Nx&?#YV$7`n*C*=qWQqp)c4qf1)2dj#*N46>Is+dApIWB|=hplW%A)EcK vqP1oMNZ$fU_7uqPuZgdJd`wvWMQePp(~C4C%!1>C?}8yh>XkFx^3UxHQim+k literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/LATEST.LOG b/queue/data/mnesia/rabbit@5c60bc6971d3/LATEST.LOG new file mode 100644 index 0000000000000000000000000000000000000000..a7b978af0245919cfef76cf2863ff88471a39ee2 GIT binary patch literal 2672 zcmc&$&2G~`5T4df;!>azMM8*2KnawVR=v?SzY*2F8aU9;RIFyAZ8@>~B zfn4;NZ&EQF$wDRM*fa|jmt*4WlXsA&wfkEi3MxwLj@fc3-phe4+>Hk{Ds#nmpzl|p z>C}jYLREp^P@|RWNcbDnwH(xNR+8}FlUNcd!RttATWZUSZ(nMqv20ovNMnMSjgeX^ z?avCwDt%tti4+=X82?BLs!e{Z==PCpwoCsd=u$vW72p{3l~kJhIZfAnUDyfWP5l{0 z#Vq@9YVDWZhjS-!Mau6-{)163VqqRq3g_v`MSYADE6;W~bZ7elNB5eWZ8V`B7U1V> P!@|wYMh(wee-QW!Q&t<_ literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/cluster_nodes.config b/queue/data/mnesia/rabbit@5c60bc6971d3/cluster_nodes.config new file mode 100644 index 0000000..505a52f --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/cluster_nodes.config @@ -0,0 +1 @@ +{[rabbit@5c60bc6971d3],[rabbit@5c60bc6971d3]}. diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/00000001.wal b/queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/00000001.wal new file mode 100644 index 0000000..698b19c --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/00000001.wal @@ -0,0 +1 @@ +RAWA \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/meta.dets b/queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/meta.dets new file mode 100644 index 0000000000000000000000000000000000000000..c1ae47e3b05f8128913ddbd12be673bebf7cc413 GIT binary patch literal 5464 zcmZQz5Vc@fefB*A0|O%zb0U~vF`zIAFfuT~7!aDSiJR2M?+wQhXC(r{vY8fVAT7gAut*OqaiRF0;3@?8UmvsFd71*Aut*O dqaiRF0wW>>1ehV?rV7xpNFE5^z!KiJR2M?+wQhXC(r{vY8fVAT7gAut*OqaiRF0;3@?8UmvsFd71*Aut*O dqaiRF0wW>>1ehV?rV7xpNFE5^z!K4t|2%27DgIAkt_-mFHY3* zYoV6kPrvD7eEItsve)eAJ!I!cvtNn7r%|DcBy018S}5PTh!iwTN?8X?lpR8u5T{xq zbgJ6~KR%F&_&;>6yln_WK)u;CwP-zc@=qE+@edB^=6%Tk`4`}oq$l!tg@*X!yz8}% zowTT7e{d^o_$@;8grYPxiqKjssp}g9`;%F}bzXDNdkH0Y(T@~S7B#chF^pr^aADy| zBXLv#W1>&*uxosfdHR_*@7$U+^qeM**7yun&o2pFeD`T;m`MXAG5t#DoLv33&|wew~TY;Z!g8-kmRsy znAYxk!j|bbD&&Xfo z6H@abdz(&z{NA&(d^A>zpHqPBrMSDkd|G~7<{EONf5Aw@0m-5;@yCgp ze=XGf?DU)dj{pB1LH2xgvx3pZ@%C-vf6}PXMUu67L@ktWT|^2RCZ((cCdwY6Oo&r0 z5jxdvg8TPmBEE<2C~q6W5KwP6ZCSLQI{7z^pZI%+w0K)GKz;kSIt+1EQcHqOp8Th?iY^Wjn{x@<)6EH6OvJ zF!mOt2yWJX$LyP#B+YU$edrUC{P5@d$;bR)o=TD``9d;D4lUzc`P)k|KI3A1eRVEJ z@bx()$@kskl4Lg*J5ND>Btd}omX+!qBo$_%Jy<76XU0kgL9%Co1xAa7wV*|_N$#(# z^6($q6Q-&yI0tgm)UBX0w&9q46#mdLD-CwKJvAZekl+dFgE*gqviQ+P$9TDB6-aX2 zHcTt`N}V?rD0oMemavX4hy5`Uui8j7Y@1M^`>`JNjF+hT8$<4!8iCA#53=qXG_`Ro z4Ub-JjR)bC(a6*bUMdmrLB$GV=@KW36iZr6=?yGK8o=5EMwJ+NW=iZfk!08K0&BKA cDG)o2dk$0y2OAqz)SZsiPV2?mi{@SLEdJ6-oP! zCj<&9(aa*E4Q90^3p!-nPzrfddD z=P>UuOLq@LCm(|-r*I3$r~pUDD5GFU!yKR*whX2e29Dy?^xV|ElHx27k2^25q9ndJ zwJ<(2C6N&%A`BKuNzKVDOD#f?;VVcjD$Xn}0cwsfN=-{);4IBcNlnYlOHBc36hM+r z&M(a?Nn}75PO2D0~Tq1{A&|BP2h=?3ZFfo literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/node-type.txt b/queue/data/mnesia/rabbit@5c60bc6971d3/node-type.txt new file mode 100644 index 0000000..342cbf2 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/node-type.txt @@ -0,0 +1 @@ +disc. diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/nodes_running_at_shutdown b/queue/data/mnesia/rabbit@5c60bc6971d3/nodes_running_at_shutdown new file mode 100644 index 0000000..7e6d243 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/nodes_running_at_shutdown @@ -0,0 +1 @@ +[rabbit@5c60bc6971d3]. diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/00000001.wal b/queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/00000001.wal new file mode 100644 index 0000000..698b19c --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/00000001.wal @@ -0,0 +1 @@ +RAWA \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/meta.dets b/queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/meta.dets new file mode 100644 index 0000000000000000000000000000000000000000..c1ae47e3b05f8128913ddbd12be673bebf7cc413 GIT binary patch literal 5464 zcmZQz5Vc@fefB*A0|O%zb0U~vF`zIAFfuT~7!aDSiJR2M?+wQhXC(r{vY8fVAT7gAut*OqaiRF0;3@?8UmvsFd71*Aut*O dqaiRF0wW>>1ehV?rV7xpNFE5^z!KiJR2M?+wQhXC(r{vY8fVAT7gAut*OqaiRF0;3@?8UmvsFd71*Aut*O dqaiRF0wW>>1ehV?rV7xpNFE5^z!K%rGL5nU0o-eL1S^#j#ug=dNqX3~fPKW)77?MJ$p}@Y`7=hOfJ0qwc zhWp*nJP>vi<2=@M>0KtrdA3SkrJ%5^$-;0ym2z9y_5tBoTeA6h( z(p(8j%r}+2A8+kOlO@w|z+{?hgkVwlTIGaL9k6k>TyGE>xkMVolJGCJwgVCTJR@ai zwN*0Rjin|f+1T_SF2LIsxG-W0t(dTYI-SJAjQY(zZ%fC1b-@N>7h^@jXkMW#ESHY? z;(}S7JRse!6S?4QqXK(b}+~{m$r`td^v9^&fNcJI76!7LmD_ aiW@5X@3ED1x53!XTvE`oDOl>*mEp~zEUVvaCSkscbF(0O)ON_NTmV7<#x^9noz4X;RnJQ*0M zph%h+^o-CmCX;6~1`W-mHH*tYeu&?Jx?LW;^3EUX~Pv&jmEC)rV+aX{F2 zLQ3N=Pt|lH)%5%<$73ByfaG05oL)#6z3nmibxn?RA7Q-q6d1U$RM3;sqFR!U5r&T1 zIyglon|g;Vd`&xH&^#kOY=VK1AX)On)Q^qqw%eMrv2;LaeC_nkkJbM^?6(Tyiz|vFBhLpP0FL6cPhQGJn3UCpE6R~-gfYsJo1g#|1z`c+Dp*8;83@xl7vkFN)-n!- zjJKNzmx>7h_ane@zXE*mHqFnjnJF7#)-fElSxVw}O`4R0;MMe~bS>#-2y2coYG3V@ Z^d}Kqq>>sM!XxeNkq+vS_4dgA9zUf3ki-B0 literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_route.DCD b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_route.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_route.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_runtime_parameters.DCD b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_runtime_parameters.DCD new file mode 100644 index 0000000000000000000000000000000000000000..ffd6e18b8d322176e9659f3635ae3b372a394f40 GIT binary patch literal 199 zcmXYpK?=e!6a~LVs@R?0LTG8Nt>{V@Du{LArXom4@`H_Ss-_hW;Bma90o^=?fj6x- z>4;FW1yX8A~5c=iqLUYMb8iXziq*fF_LO&>=H}S`zZwFy$80V^4#3Bi}NM_Rz zqnvO6=fk1XopW&C#+J{&GC>%aXVoYz>75y-Wg|^(Gpe#sv671NSzDwEwY`mgdHwMI Z-c#spYE`Xdx-scWXV)m+Z%^yT>kIS0I`;qo literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_serial b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_serial new file mode 100644 index 0000000..d54c6b6 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_serial @@ -0,0 +1 @@ +1. diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_topic_permission.DCD b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_topic_permission.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_topic_permission.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCD b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCL b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCL new file mode 100644 index 0000000000000000000000000000000000000000..68212098d5769084515ee1f7589ab559728a6d09 GIT binary patch literal 433 zcmZQ%VrEH>@a1M;UH&!q2H~Q_q@>Ie2h(ITgQR3LOLM~%;|%5`1_rj(Nes*%Pb4vLiFW`^o(eIU zIfE&Mfg7SHzO*>CC>JQlo?DohlAD@a1M;UH&!q2H~Q_q@>Ie2h(ITgQR3LOLM~%;|%5`1_rj(Nes*%Pb4vLDb50#yZ~Y{ za|TligBV0ld}(oNQG7vaQEp~&ab|vA1~brFuvl3}esM`IP#1e{VPZ;dW*&&ms1H)W bPqHQ!ps5H;KqfKiX`xan46NlvnI)+JkD5vS literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCD b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCL b/queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCL new file mode 100644 index 0000000000000000000000000000000000000000..a0af58ecde586192a2f9b054218a88ef877725ef GIT binary patch literal 209 zcmYj}yA8rH6h$9#_|w4vnII6pq63K%8XD*#+t0*K3_*^80T_ox7=T6SDKJVybEW$` z6_5CQzi9)&mhINdyR0F!be_agP!tBCj$Fqs$bdxQAcMv@97drNgs!2CDZ7~P>45R+ zd=}wI5(ZFvFd*+IgXZVu$Vo{i(nIK!pZF^C!X8~&=}RA>`sY*YVmEE0D7aB)tMb!t d*;|PNy=WU;m9ZD9gC7FHw=^kIhqxJK#TUJ0I+_3g literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@5c60bc6971d3/schema.DAT b/queue/data/mnesia/rabbit@5c60bc6971d3/schema.DAT new file mode 100644 index 0000000000000000000000000000000000000000..35e9e0c856b78fd25d2b3c2da97313017b376ca9 GIT binary patch literal 27322 zcmeHQO^h5z6|U}?*`1x)@vg_~-8jZxb07(p2#H8cEQDf+!i_@?2?7bXYP!oaz3HDx z|Ez5gvL%GzfJ99AIe@|~2n+}mPB}Or#34dRNV((|B~pY0hmeE=;GgiSx@xwor)PF| zc6xU_Q(%?-t9tKM8zK7wy8hR95keaOTiE)FbSPU*{xnALHt>=AuL7lY z_$%es?xFC|=YM_=`olMlKVkmr{xAIbyJz;$)tG)-d2CD_scsYp6bJ4)4m1@0@47Wp z53D$#IG{M7IG{LC6bH%=B1BSq1KmaFb1Ay0are7l4bF^bCtzOM%LpAE@*H{tp^p!# zFPd-q`v^U?598}65jvJLj&>8FkL8pXJ#W!}`5Hn`9^m-mIn-yu0eu~z&lb2I`U41k z75dk1A+$z6KS1dI5ysQOm-O%mzss(3d*%ZlSV=UD7LNCDG+B zl$1geQL+|b*D(FAO~MUI*DX6Vc>(Q3v(S+Mw_0{|?osp1LoM^n*-t-geTubRW^H}X zxt#8y=J?n${J|4X}P3%CY zUPQbI8ePCn$ePy!VnWwO-?VBtiUPY8M{rF7?Z%xC>A!hAfHibh^P40HZQp}m z>sZHVV`Iz$rQPD||8IHy7n8LzHamV8QARZB<8UdEDp~nt$wJk|8$Jle<@Ad0NkA%$ z4|J*-`2fr;ZrVWDAk# z3zB{^S$}<1UjI5@e=6qLw*ZOHA33BLx*$ZCaIRlSUVZ;YF%lIymeA zY9ibQc{ofd+iM%xX;bO!xIJMhL_&V_(s!Qc5^`k{RLz(*m+EdD9MBJQ{4dD(UrpiP z02}ApA+q5uZ9n+XlDoaIiw3RuZDGoB@|H7!~hyw?7gPzL9fGMIKCk2pW=CO`ju zAlv^Hj(;nLFAgyRA5O$s>z~_bCXioY{K$v(eD$YqBFqH!T6JQ7qNnI_=F1Z103|aJ70cD ztox0`%ul)A=+|6&?90l>(6{RRrh?uRf`UBklpUTI7;<|!}I59j3yAQ&DrdbOA z(|;yh%9(sd4?vW7p~pke62t51 zKAU_+mry)=VHrl-2%xGyP!8zp-2Si0_!nNilx^d7Dyt9%w@hh>>E8u3`#DADpV1jm zvdA_9`{4_?{gbo8?7yhC_y-EJi5*;bIsS=^e-YOgu77dX&7yx$yA<|wb_abSAKLA( z@X%yNgQ|inIY_VfvSrIja_l^3C8S2yLuiwArA;Ol(7SxF z@->eCr)B&v@%W#R@GS1L^~3SL9lY<7=y|lUDe1> zDamP)7OfU;GhMrN*cY%n7(-){NE>u-tZlX5EWQWLA@iUa%40sT;k zy*EvtlU21i)d%3Cwq3Z3ghA!Pel=is45?WxIh$1s z_Y=%RJSXW(@)%UY2vaA-p~RnH@ax7FI=(d+-2Pzs%tqLWBMTmwCN?K`U4_G;r{`S8)LFfjkmwS&M1>u7{=*DyP_V})H}_Nlu3W;3PgRtNJS6a5D- zZsG-KBtM}q17Vx}g&u7K#Ik1BwHR16v#@Kgj)mnf(8g zJXFgzPFH+rIf)jc8bY6;ZxLPLH2iN#Uj!P{ zGSOxcAvaAQLMTqt%Lx52O&>os#G^bWWo0L02XE qn3lYOTRi{0x=bH0%k)R8GJRrMrca)d>Gg97y_oRqp|c2Wyz+lvVC2F8 literal 0 HcmV?d00001