From a1854a726a33ac113e5ebeadaec8d56fb93acdad Mon Sep 17 00:00:00 2001 From: Peter Kotyczka Date: Fri, 9 Feb 2024 10:39:42 +0100 Subject: [PATCH] queue folder --- app/queue/__pycache__/config.cpython-311.pyc | Bin 0 -> 212 bytes app/queue/ampq_client.py | 45 +++++++ app/queue/ampq_receiver.py | 29 +++++ app/queue/ampq_sender.py | 52 +++++++++ app/queue/ampq_server.py | 51 ++++++++ app/queue/client_http.py | 96 +++++++++++++++ app/queue/config.py | 5 + app/queue/connect.json | 0 app/queue/db_receive.py | 79 +++++++++++++ app/queue/db_send.py | 110 ++++++++++++++++++ app/queue/send.py | 6 + app/queue/test.py | 39 +++++++ 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 .../mnesia/rabbit@deb2ec87ffa7-feature_flags | 17 +++ .../rabbit@deb2ec87ffa7/DECISION_TAB.LOG | Bin 0 -> 161 bytes .../mnesia/rabbit@deb2ec87ffa7/LATEST.LOG | Bin 0 -> 100 bytes .../rabbit@deb2ec87ffa7/cluster_nodes.config | 1 + .../rabbit@deb2ec87ffa7/00000001.wal | 1 + .../rabbit@deb2ec87ffa7/meta.dets | Bin 0 -> 5464 bytes .../rabbit@deb2ec87ffa7/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 .../3MG1WRJOAKASZ3ST4MWZJXJ0Z/.queue_name | 2 + .../queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/0.idx | Bin 0 -> 241 bytes .../3MG1WRJOAKASZ3ST4MWZJXJ0Z/journal.jif | 0 .../5BY898XLEGEBFE6E2YXLPN9EB/.queue_name | 2 + .../5BY898XLEGEBFE6E2YXLPN9EB/journal.jif | 0 .../E85S9NV9WF5Q6B2OSTL9P9EL9/.queue_name | 2 + .../queues/E85S9NV9WF5Q6B2OSTL9P9EL9/0.idx | Bin 0 -> 241 bytes .../E85S9NV9WF5Q6B2OSTL9P9EL9/journal.jif | 0 .../628WB79CIFDYO9LJI6DKMI09L/recovery.dets | Bin 0 -> 6736 bytes .../mnesia/rabbit@deb2ec87ffa7/node-type.txt | 1 + .../nodes_running_at_shutdown | 1 + .../quorum/rabbit@deb2ec87ffa7/00000001.wal | 1 + .../quorum/rabbit@deb2ec87ffa7/meta.dets | Bin 0 -> 5464 bytes .../quorum/rabbit@deb2ec87ffa7/names.dets | Bin 0 -> 5464 bytes .../rabbit_durable_exchange.DCD | Bin 0 -> 1673 bytes .../rabbit_durable_queue.DCD | 1 + .../rabbit_durable_route.DCD | 1 + .../rabbit_runtime_parameters.DCD | Bin 0 -> 199 bytes .../mnesia/rabbit@deb2ec87ffa7/rabbit_serial | 1 + .../rabbit_topic_permission.DCD | 1 + .../rabbit@deb2ec87ffa7/rabbit_user.DCD | 1 + .../rabbit@deb2ec87ffa7/rabbit_user.DCL | Bin 0 -> 433 bytes .../rabbit_user_permission.DCD | 1 + .../rabbit_user_permission.DCL | Bin 0 -> 266 bytes .../rabbit@deb2ec87ffa7/rabbit_vhost.DCD | 1 + .../rabbit@deb2ec87ffa7/rabbit_vhost.DCL | Bin 0 -> 209 bytes .../mnesia/rabbit@deb2ec87ffa7/schema.DAT | Bin 0 -> 27322 bytes 99 files changed, 595 insertions(+) create mode 100644 app/queue/__pycache__/config.cpython-311.pyc create mode 100644 app/queue/ampq_client.py create mode 100644 app/queue/ampq_receiver.py create mode 100644 app/queue/ampq_sender.py create mode 100644 app/queue/ampq_server.py create mode 100644 app/queue/client_http.py create mode 100644 app/queue/config.py create mode 100644 app/queue/connect.json create mode 100644 app/queue/db_receive.py create mode 100644 app/queue/db_send.py create mode 100644 app/queue/send.py create mode 100644 app/queue/test.py 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 create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7-feature_flags create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/DECISION_TAB.LOG create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/LATEST.LOG create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/cluster_nodes.config create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/coordination/rabbit@deb2ec87ffa7/00000001.wal create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/coordination/rabbit@deb2ec87ffa7/meta.dets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/coordination/rabbit@deb2ec87ffa7/names.dets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/.config create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/0.rdq create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/clean.dot create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/file_summary.ets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/msg_store_index.ets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/0.rdq create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/clean.dot create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/file_summary.ets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/msg_store_index.ets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/.queue_name create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/0.idx create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/journal.jif create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/.queue_name create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/journal.jif create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/.queue_name create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/0.idx create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/journal.jif create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/recovery.dets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/node-type.txt create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/nodes_running_at_shutdown create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/00000001.wal create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/meta.dets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/names.dets create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_durable_exchange.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_durable_queue.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_durable_route.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_runtime_parameters.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_serial create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_topic_permission.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCL create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCL create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCD create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCL create mode 100644 queue/data/mnesia/rabbit@deb2ec87ffa7/schema.DAT diff --git a/app/queue/__pycache__/config.cpython-311.pyc b/app/queue/__pycache__/config.cpython-311.pyc new file mode 100644 index 0000000000000000000000000000000000000000..c0baa2becefefdcd1a8a3cc94b1260bfe53b3e73 GIT binary patch literal 212 zcmZ3^%ge<81a*-|Q$vCDV-N=h7@>^Md_cx@h7^V<5N1qa3}(<|y2V_aTj2+!IZBID zi}Dh4Q*Ut;Bo-H!=NF}{WcUoy`pZ>66ew4$pPgS)nOv2fs9%&?kYAixl3$dWiX@s? zP*AL&l9ia3p05vN>lc=$mZs__=jWwmrt1|{{^GF7%}*)KNwq8D0GbMNRk1LT_`uA_ U$asTWpn(HSG;lO<6tMxt0V%#aZ~y=R literal 0 HcmV?d00001 diff --git a/app/queue/ampq_client.py b/app/queue/ampq_client.py new file mode 100644 index 0000000..3d6258a --- /dev/null +++ b/app/queue/ampq_client.py @@ -0,0 +1,45 @@ +import optparse +from proton import Message +from proton.handlers import MessagingHandler +from proton.reactor import Container + + +class Client(MessagingHandler): + def __init__(self, url, requests): + super(Client, self).__init__() + self.url = url + self.requests = requests + + def on_start(self, event): + self.sender = event.container.create_sender(self.url) + self.receiver = event.container.create_receiver(self.sender.connection, None, dynamic=True) + + def next_request(self): + if self.receiver.remote_source.address: + req = Message(reply_to=self.receiver.remote_source.address, body=self.requests[0]) + self.sender.send(req) + + def on_link_opened(self, event): + if event.receiver == self.receiver: + self.next_request() + + def on_message(self, event): + print("%s => %s" % (self.requests.pop(0), event.message.body)) + if self.requests: + self.next_request() + else: + event.connection.close() + + +REQUESTS = ["Twas brillig, and the slithy toves", + "Did gire and gymble in the wabe.", + "All mimsy were the borogroves,", + "And the mome raths outgrabe."] + +parser = optparse.OptionParser(usage="usage: %prog [options]", + description="Send requests to the supplied address and print responses.") +parser.add_option("-a", "--address", default="localhost:5672/examples", + help="address to which messages are sent (default %default)") +opts, args = parser.parse_args() + +Container(Client(opts.address, args or REQUESTS)).run() \ No newline at end of file diff --git a/app/queue/ampq_receiver.py b/app/queue/ampq_receiver.py new file mode 100644 index 0000000..f8fe8a9 --- /dev/null +++ b/app/queue/ampq_receiver.py @@ -0,0 +1,29 @@ +import optparse +import time +import os +import sys +from proton import Message +from proton.utils import BlockingConnection +from proton.handlers import IncomingMessageHandler + +broker = '5672' ##os.getenv('AMQP_BROKER_HOST_PORT') +queue = 'proton' ##os.getenv('AMQP_ADDRESS') +user_arg = 'smx' ##os.getenv('AMQP_USER') +userpw_arg = 'smx' ##os.getenv('AMQP_USER_PASSWORD') + +conn = BlockingConnection(broker, user=user_arg, password=userpw_arg) +receiver = conn.create_receiver(queue) + +count = 0 +try: + while True: + msg = receiver.receive(timeout=None) + count += 1 + print("got message, processing for two seconds...") + sys.stdout.flush() + time.sleep(2) + receiver.accept() +finally: + conn.close() + +print ("All done. Processed ", count, " messages.") \ No newline at end of file diff --git a/app/queue/ampq_sender.py b/app/queue/ampq_sender.py new file mode 100644 index 0000000..ef7984c --- /dev/null +++ b/app/queue/ampq_sender.py @@ -0,0 +1,52 @@ +from __future__ import print_function, unicode_literals +import optparse +from proton import Message +from proton.handlers import MessagingHandler +from proton.reactor import Container +from proton.utils import BlockingConnection +from django.conf import settings + +broker = '5672' ##os.getenv('AMQP_BROKER_HOST_PORT') +queue = 'proton' ##os.getenv('AMQP_ADDRESS') +user_arg = 'smx' ##os.getenv('AMQP_USER') +userpw_arg = 'smx' ##os.getenv('AMQP_USER_PASSWORD') + +class Send(MessagingHandler): + def __init__(self, url, messages): + super(Send, self).__init__() + self.url = url + self.sent = 0 + self.confirmed = 0 + self.total = messages + + def on_start(self, event): + event.container.create_sender(self.url) + + def on_sendable(self, event): + while event.sender.credit and self.sent < self.total: + msg = Message(id=(self.sent+1), body={'sequence':(self.sent+1)}) + event.sender.send(msg) + self.sent += 1 + + def on_accepted(self, event): + self.confirmed += 1 + if self.confirmed == self.total: + print("all messages confirmed") + event.connection.close() + + def on_disconnected(self, event): + self.sent = self.confirmed + +conn = BlockingConnection(broker, user=user_arg, password=userpw_arg) + +parser = optparse.OptionParser(usage="usage: %prog [options]", + description="Send messages to the supplied address.") +parser.add_option("-a", "--address", default="0.0.0.0:16161/examples", + help="address to which messages are sent (default %default)") +parser.add_option("-m", "--messages", type="int", default=100, + help="number of messages to send (default %default)") +opts, args = parser.parse_args() + +try: + Container(Send(opts.address, opts.messages)).run() +except KeyboardInterrupt: pass \ No newline at end of file diff --git a/app/queue/ampq_server.py b/app/queue/ampq_server.py new file mode 100644 index 0000000..c4534f9 --- /dev/null +++ b/app/queue/ampq_server.py @@ -0,0 +1,51 @@ +import optparse +import sys +from proton import Condition, Message, Url +from proton.handlers import MessagingHandler +from proton.reactor import Container + +exit_status = 0 + + +class Server(MessagingHandler): + def __init__(self, url, address): + super(Server, self).__init__() + self.url = url + self.address = address + + def on_start(self, event): + print("Listening on", self.url) + self.container = event.container + self.conn = event.container.connect(self.url, desired_capabilities="ANONYMOUS-RELAY") + + def on_connection_opened(self, event): + if event.connection.remote_offered_capabilities and 'ANONYMOUS-RELAY' in event.connection.remote_offered_capabilities: + self.receiver = event.container.create_receiver(self.conn, self.address) + self.server = self.container.create_sender(self.conn, None) + else: + global exit_status + print("Server needs a broker which supports ANONYMOUS-RELAY", file=sys.stderr) + exit_status = 1 + c = event.connection + c.condition = Condition('amqp:not-implemented', description="ANONYMOUS-RELAY required") + c.close() + + def on_message(self, event): + print("Received", event.message) + self.server.send(Message(address=event.message.reply_to, body=event.message.body.upper(), + correlation_id=event.message.correlation_id)) + + +parser = optparse.OptionParser(usage="usage: %prog [options]") +parser.add_option("-a", "--address", default="localhost:5672/examples", + help="address from which messages are received (default %default)") +opts, args = parser.parse_args() + +url = Url(opts.address) + +try: + Container(Server(url, url.path)).run() +except KeyboardInterrupt: + pass + +sys.exit(exit_status) \ No newline at end of file diff --git a/app/queue/client_http.py b/app/queue/client_http.py new file mode 100644 index 0000000..6ca4b4c --- /dev/null +++ b/app/queue/client_http.py @@ -0,0 +1,96 @@ +import tornado.ioloop +import tornado.web +from tornado.gen import coroutine +from tornado.concurrent import Future +from proton import Message +from proton.handlers import MessagingHandler +from proton_tornado import Container + + +class Client(MessagingHandler): + def __init__(self, host, address): + super(Client, self).__init__() + self.host = host + self.address = address + self.sent = [] + self.pending = [] + self.reply_address = None + self.sender = None + self.receiver = None + + def on_start(self, event): + conn = event.container.connect(self.host) + self.sender = event.container.create_sender(conn, self.address) + self.receiver = event.container.create_receiver(conn, None, dynamic=True) + + def on_link_opened(self, event): + if event.receiver == self.receiver: + self.reply_address = event.link.remote_source.address + self.do_request() + + def on_sendable(self, event): + self.do_request() + + def on_message(self, event): + if self.sent: + request, future = self.sent.pop(0) + print("%s => %s" % (request, event.message.body)) + future.set_result(event.message.body) + self.do_request() + + def do_request(self): + if self.pending and self.reply_address and self.sender.credit: + request, future = self.pending.pop(0) + self.sent.append((request, future)) + req = Message(reply_to=self.reply_address, body=request) + self.sender.send(req) + + def request(self, body): + future = Future() + self.pending.append((body, future)) + self.do_request() + self.container.touch() + return future + + +class ExampleHandler(tornado.web.RequestHandler): + def initialize(self, client): + self.client = client + + def get(self): + self._write_open() + self._write_form() + self._write_close() + + @coroutine + def post(self): + response = yield self.client.request(self.get_body_argument("message")) + self.set_header("Content-Type", "text/html") + self._write_open() + self._write_form() + self.write("Response: " + response) + self._write_close() + + def _write_open(self): + self.write('') + + def _write_close(self): + self.write('') + + def _write_form(self): + self.write('
' + 'Request: ' + '' + '
') + + +loop = tornado.ioloop.IOLoop.instance() +client = Client("localhost:5672", "examples") +client.container = Container(client, loop=loop) +client.container.initialise() +app = tornado.web.Application([tornado.web.url(r"/client", ExampleHandler, dict(client=client))]) +app.listen(8888) +try: + loop.start() +except KeyboardInterrupt: + loop.stop() \ No newline at end of file diff --git a/app/queue/config.py b/app/queue/config.py new file mode 100644 index 0000000..8bc7a07 --- /dev/null +++ b/app/queue/config.py @@ -0,0 +1,5 @@ +username = 'smx' +password = 'smx' + +#username = 'mqadmin' +#password = '3Mnj29jKBsFybc' \ No newline at end of file diff --git a/app/queue/connect.json b/app/queue/connect.json new file mode 100644 index 0000000..e69de29 diff --git a/app/queue/db_receive.py b/app/queue/db_receive.py new file mode 100644 index 0000000..88d44fc --- /dev/null +++ b/app/queue/db_receive.py @@ -0,0 +1,79 @@ +#!/usr/bin/env python3 +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# + +import optparse +from proton.handlers import MessagingHandler +from proton.reactor import ApplicationEvent, Container, EventInjector +from db_common import Db + + +class Recv(MessagingHandler): + def __init__(self, url, count): + super(Recv, self).__init__(auto_accept=False) + self.url = url + self.delay = 0 + self.last_id = None + self.expected = count + self.received = 0 + self.accepted = 0 + self.db = Db("dst_db", EventInjector()) + + def on_start(self, event): + event.container.selectable(self.db.injector) + e = ApplicationEvent("id_loaded") + e.container = event.container + self.db.get_id(e) + + def on_id_loaded(self, event): + self.last_id = event.id + event.container.create_receiver(self.url) + + def on_record_inserted(self, event): + self.accept(event.delivery) + self.accepted += 1 + if self.accepted == self.expected: + event.connection.close() + self.db.close() + + def on_message(self, event): + id = int(event.message.id) + if (not self.last_id) or id > self.last_id: + if self.expected == 0 or self.received < self.expected: + self.received += 1 + self.last_id = id + self.db.insert(id, event.message.body, ApplicationEvent("record_inserted", delivery=event.delivery)) + print("inserted message %s" % id) + else: + self.release(event.delivery) + else: + self.accept(event.delivery) + + +parser = optparse.OptionParser(usage="usage: %prog [options]") +parser.add_option("-a", "--address", default="localhost:5672/examples", + help="address from which messages are received (default %default)") +parser.add_option("-m", "--messages", type="int", default=0, + help="number of messages to receive; 0 receives indefinitely (default %default)") +opts, args = parser.parse_args() + +try: + Container(Recv(opts.address, opts.messages)).run() +except KeyboardInterrupt: + pass \ No newline at end of file diff --git a/app/queue/db_send.py b/app/queue/db_send.py new file mode 100644 index 0000000..71e97c5 --- /dev/null +++ b/app/queue/db_send.py @@ -0,0 +1,110 @@ +#!/usr/bin/env python3 +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# + +import optparse +import queue + + +from proton import Message +from proton.handlers import MessagingHandler +from proton.reactor import ApplicationEvent, Container, EventInjector +from db_common import Db + + +class Send(MessagingHandler): + def __init__(self, url, count): + super(Send, self).__init__() + self.url = url + self.delay = 0 + self.sent = 0 + self.confirmed = 0 + self.load_count = 0 + self.records = queue.Queue(maxsize=50) + self.target = count + self.db = Db("src_db", EventInjector()) + + def keep_sending(self): + return self.target == 0 or self.sent < self.target + + def on_start(self, event): + self.container = event.container + self.container.selectable(self.db.injector) + self.sender = self.container.create_sender(self.url) + + def on_records_loaded(self, event): + if self.records.empty(): + if event.subject == self.load_count: + print("Exhausted available data, waiting to recheck...") + # check for new data after 5 seconds + self.container.schedule(5, self) + else: + self.send() + + def request_records(self): + if not self.records.full(): + print("loading records...") + self.load_count += 1 + self.db.load(self.records, event=ApplicationEvent( + "records_loaded", link=self.sender, subject=self.load_count)) + + def on_sendable(self, event): + self.send() + + def send(self): + while self.sender.credit and not self.records.empty(): + if not self.keep_sending(): + return + record = self.records.get(False) + id = record['id'] + self.sender.send(Message(id=id, durable=True, body=record['description']), tag=str(id)) + self.sent += 1 + print("sent message %s" % id) + self.request_records() + + def on_settled(self, event): + id = int(event.delivery.tag) + self.db.delete(id) + print("settled message %s" % id) + self.confirmed += 1 + if self.confirmed == self.target: + event.connection.close() + self.db.close() + + def on_disconnected(self, event): + self.db.reset() + self.sent = self.confirmed + + def on_timer_task(self, event): + print("Rechecking for data...") + self.request_records() + + +parser = optparse.OptionParser(usage="usage: %prog [options]", + description="Send messages to the supplied address.") +parser.add_option("-a", "--address", default="localhost:5672/examples", + help="address to which messages are sent (default %default)") +parser.add_option("-m", "--messages", type="int", default=0, + help="number of messages to send; 0 sends indefinitely (default %default)") +opts, args = parser.parse_args() + +try: + Container(Send(opts.address, opts.messages)).run() +except KeyboardInterrupt: + pass \ No newline at end of file diff --git a/app/queue/send.py b/app/queue/send.py new file mode 100644 index 0000000..ecef4d7 --- /dev/null +++ b/app/queue/send.py @@ -0,0 +1,6 @@ +import stomp + +conn = stomp.Connection() +conn.connect('smx', 'smx', wait=True) +conn.send(content_type='application/raw',body=' Hello Stomp ', destination='/queue/test') +conn.disconnect() \ No newline at end of file diff --git a/app/queue/test.py b/app/queue/test.py new file mode 100644 index 0000000..2a7d68c --- /dev/null +++ b/app/queue/test.py @@ -0,0 +1,39 @@ +import stomp +from stomp.listener import TestListener +import testutils + + +##@pytest.fixture() +def conn(): + conn = stomp.Connection11(get_artemis_host()) + conn.set_listener("testlistener", TestListener("123", print_to_log=True)) + conn.connect(get_artemis_user(), get_artemis_password(), wait=True) + yield conn + conn.disconnect(receipt=None) + + +##@pytest.fixture() +def conn2(): + conn2 = stomp.Connection11(get_artemis_host()) + conn2.set_listener("testlistener", TestListener("456", print_to_log=True)) + conn2.connect(get_artemis_user(), get_artemis_password(), wait=True, headers={'consumerWindowSize': 0}) + yield conn2 + conn2.disconnect(receipt=None) + + +class TestArtemis(object): + + def test_send_to_artemis(self, conn): + conn.subscribe(destination="/queue/test", id=1, ack="auto") + + conn.send(body="this is a test", destination="/queue/test", receipt="123") + + validate_send(conn) + + def test_prefetchsize(self, conn2): + conn2.subscribe(destination="/queue/test2", id=2, ack="auto", headers={'consumerWindowSize': 0}) + + conn2.send(body="testing sending a message after subscribing with prefetch", + destination="/queue/test2", receipt="456") + + validate_send(conn2) \ No newline at end of file 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 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7-feature_flags b/queue/data/mnesia/rabbit@deb2ec87ffa7-feature_flags new file mode 100644 index 0000000..5d4247e --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7-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@deb2ec87ffa7/DECISION_TAB.LOG b/queue/data/mnesia/rabbit@deb2ec87ffa7/DECISION_TAB.LOG new file mode 100644 index 0000000000000000000000000000000000000000..5f6c40f1ad53b9416ceb7dc3064d9d419040ed39 GIT binary patch literal 161 zcmX}ku?~VT6h`46ibO>x--8G-fx$s{ozaQ(a*M4rkhFaRA4eZj5)+rRoaBpQk#x6f z2B4wla(?NQv9{Br)k?B*j18;Kcr%S{kTgIP`F_Cike5Y1hp}^#$b=IsDpglkeJ?95 s2uR@a1M;UiJR2M?+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_C zBJlzI244{|-Yss6!_9i@1&5)$(!yki8Z^F3#^(pH{hs+~}V$(XdalC`>%l zSe&5xc3PJ56rcaSz~ukY!xzY&?jNrb|3ITc7fIIU7PU~mbrC6On3b{)m?*o1G9ga2 zMCepE2KTPXM0^jOD{mXZ5Kxbswk%pto&1}|&-}GRT5gsMkRJoDBt4O*D>TF(=UuOD z>ZC;thl5*T!!Hq{ClsZrQH0i7NnPI<*q_Y$t@E0DHYJqcML$wRS=7v0$1sgu!-a(> zjl@v}jETPW8@t8_nWvw5Lq4L4#yduuwy2Ft^&KlKPvQ?J%g`WW#~L@PLC?dRh>q0> z<4Rw%@l3-J5S{%bMM5M#5(PDiM1=%JD4~ZM1cl|#Eb+2yuWW~8X*mKNEd|#=;s9KM zlOV>s1u24?wcls<%}kPJxxBd=10>(#`tss=zB^A9q*~oVreM!;A#^xbC{9qG&5DB0 z@blvfvY+Ye6q5Isx4Wp{S18d0$1DAWib=aL0i9PcD0t;DO12&H$QZeB4vlQr$(^Os z0smu1($ zhFR_JnGe<>!{C`V3Rj)WQ-2(~tFejc2}HlPgJ8e*D-sI-juq~@h{?2#r)6i<3gn>DP9G{IFsimE7ZVJqr3QLtr2Nj3YO cl!P61dyZ@@eMkmoi#}*)iPZ<)204`FFVDrRGynhq literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/0.rdq b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/0.rdq new file mode 100644 index 0000000..e69de29 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/clean.dot b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/clean.dot new file mode 100644 index 0000000..537b343 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/clean.dot @@ -0,0 +1,2 @@ +{client_refs,[]}. +{index_module,rabbit_msg_store_ets_index}. diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/file_summary.ets b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/file_summary.ets new file mode 100644 index 0000000000000000000000000000000000000000..a8c98d74ca2a381655c34ace9199e7e837185a9b GIT binary patch literal 619 zcmZ`%Jx?4l5S`uoP`KkH2oha76e&uV=1?l=p#~*|<+W#X-mLA_*qdW%`3ZDTrpVtw z$`9ag@CPW781EKbakyFUyf@?bo}J~RvAR5;17uId#o6i2>fY80WhR#MkD2KFbje(SvEo^1&wc;1f`Q5H3`-eMTXuHnMm zlSbmG0>(t2{>HBHLFVaa){u{=qVbNArY<Qhi}%J5S{%bMM5M#5(PCvLUd4s5_+hKps@UzC0=&zmFfb9G0`2dpFr)1U_lqjC`m^N!z7iog4fD~0x;KEkaZK7bqijr#f dJ1Ge}?DiblSbCof%ocsn&JwE+x(#wD%O6(0tN;K2 literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/.queue_name b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/.queue_name new file mode 100644 index 0000000..a50e1df --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/.queue_name @@ -0,0 +1,2 @@ +VHOST: / +QUEUE: B diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/0.idx b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/0.idx new file mode 100644 index 0000000000000000000000000000000000000000..d099f3b7e0c15a6071bb62598c04cac11681e32a GIT binary patch literal 241 zcmZo*O!SKNe1G!GUnQX7pRC)A1IJok(`m3mkt(SEvQUMEz1E(f#sdDK&G%K=jWBA=9MJcq%g4L z<>!HwGBGfuFh~|9CM9K-#HSS{=4R%l$0z0%7Q`FGTgDs0%~12t%c)c-$;d2L0NIn5 inxl}Mn5R&jnhFtwx-AQ2p8&e2QW#j%5_5`E9T)))97zxW literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/journal.jif b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/3MG1WRJOAKASZ3ST4MWZJXJ0Z/journal.jif new file mode 100644 index 0000000..e69de29 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/.queue_name b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/.queue_name new file mode 100644 index 0000000..3b94b0d --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/.queue_name @@ -0,0 +1,2 @@ +VHOST: / +QUEUE: AllInfo diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/journal.jif b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/journal.jif new file mode 100644 index 0000000..e69de29 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/.queue_name b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/.queue_name new file mode 100644 index 0000000..241c546 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/.queue_name @@ -0,0 +1,2 @@ +VHOST: / +QUEUE: C diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/0.idx b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/0.idx new file mode 100644 index 0000000000000000000000000000000000000000..79fa910c361930f2cecb2ef1b134e55395eda116 GIT binary patch literal 241 zcmZo*^b+=4*nXm}tZ>@PNlS0-ieW$iH6ZhBa|T-q18-7dab|LSZfbFHVtQ%@O9}%= zQEG91X;E@&E>IDpK2RXFA~_>5FC8qvT2PsiT9yNn0?RvRflOgf&d)1J%_~W?Nnv2g z%g+NVWny4RVUR3JOiIcuiBBs^%+1V8k59}kEQmLVw~RN0o1x~Pms6=wl95@g0J0}9 jHAf*iF;Ag5H5DQVbz2t5J^^%3r7*CjCFT^TIxqqNM-54% literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/journal.jif b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/E85S9NV9WF5Q6B2OSTL9P9EL9/journal.jif new file mode 100644 index 0000000..e69de29 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/recovery.dets b/queue/data/mnesia/rabbit@deb2ec87ffa7/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/recovery.dets new file mode 100644 index 0000000000000000000000000000000000000000..d41375ef6194b033aba4cafc60c5aa40b7f2d44e GIT binary patch literal 6736 zcmZQzkodr``s{lK1_nkb=0q^TVk|&$AZBD>0y2OAqz)SZsiPTqV;joy=2?4>n$C&Hn=x^rQBUhQMeDjE2By2#kinXb22+2<%{B zkigd#I?TWzj!%A|-9KFH2Zpm4HNqJfpQ6+-XSjsxs6R$SU^E0qLjXMlb_kh-RR9Gy zG-ohnGf0{`MOs)|MEJP6yE?hKnzl5}!@X!-Ks19lafcql|+?Onk$m zydt~|qK2#g(bK=Tv#GDCd#IbKyQN2%p^1;DQHV)Yh>HcL|1l#Sm>O`Tf9glN05fF1 zgPVat64cIt@p%{+WRdy23=FEsd_D#SQ)E6r14Ae>Ux0yODl%V?ff3w}f|)PGz=XmV zW?(_#i!gAY@I@H}Q21gD3MhPW1_u2hj)U1R#e~Y2W&K1yK2N U3aET}2MC`B5}pQ@3=C2M06_3P(EtDd literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/node-type.txt b/queue/data/mnesia/rabbit@deb2ec87ffa7/node-type.txt new file mode 100644 index 0000000..342cbf2 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/node-type.txt @@ -0,0 +1 @@ +disc. diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/nodes_running_at_shutdown b/queue/data/mnesia/rabbit@deb2ec87ffa7/nodes_running_at_shutdown new file mode 100644 index 0000000..e54375d --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/nodes_running_at_shutdown @@ -0,0 +1 @@ +[rabbit@deb2ec87ffa7]. diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/00000001.wal b/queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/00000001.wal new file mode 100644 index 0000000..698b19c --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/00000001.wal @@ -0,0 +1 @@ +RAWA \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/meta.dets b/queue/data/mnesia/rabbit@deb2ec87ffa7/quorum/rabbit@deb2ec87ffa7/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!KGUris%!4uYBYfDMF-#LDC0G_*n$ zm5^JqBxff&|MJUUSK2FA#LZ5X zot;*XW(*^#Z29Iw+hWno^O=fMgHT%*|HInR(X1<#A+1I8V|JlN5CNi17 zJ6?Ro){57$pIxxQ+C`~JSk1-QeR9F9P9Ko&HVVzdyS34sgm!7OV6Cq%TANvDzcaca kt2?Si3thhb$_BzrJ*rNYf;LRCQglMKIwLC$6)R|5JX(!ZVySPdU%tGP Zzb6t&gje<2Mu+r8YHWhzbE8~0{Q@u6J8%F1 literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_serial b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_serial new file mode 100644 index 0000000..d54c6b6 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_serial @@ -0,0 +1 @@ +1. diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_topic_permission.DCD b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_topic_permission.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_topic_permission.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCD b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCL b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user.DCL new file mode 100644 index 0000000000000000000000000000000000000000..9860aa9edb0269079e6d0e831600d2126a46ce4b GIT binary patch literal 433 zcmZQ%VrEH>@a1M;UH&!q2H~Q_q@>Iehm_PLqts*z^R%=?^9<%B1_rj(NerwEIY|s`w(Ef=PlcGw zoWYdBzzxw8Us{}6lnaz&&n-+$$<53I*~^=mSCU$kmzaYg3sR{v>&$Z3D-mq7a%Y!S zEx$FlV)Hhg6z?9EjjLf|B_~ML2 sBU7^ypivAd46NlvnI)+}<|_I*E(d5GBhZ^*4`&va6eX7A7m?^<0MEjZH2?qr literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCD b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCL b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_user_permission.DCL new file mode 100644 index 0000000000000000000000000000000000000000..09d1259df37fe5217f852b59e3969e0757c82006 GIT binary patch literal 266 zcmZQ%VrEH>@a1M;UH&!q2H~Q_q@>Iehm_PLqts*z^R%=?^9<%B1_rj(NerwEIY|s`?mK`cFMycL zoWYdBAO_JBUs{}66km{9l$%*xoSC1O!3?w(ELN70UtE$4)Wx1#n3$5AnFnGs>Vp*U bldOpaXez=IkV#B>TBuYC18aFvW=SdlZD&cj literal 0 HcmV?d00001 diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCD b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCD new file mode 100644 index 0000000..f8dd237 --- /dev/null +++ b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCD @@ -0,0 +1 @@ +cXM \ No newline at end of file diff --git a/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCL b/queue/data/mnesia/rabbit@deb2ec87ffa7/rabbit_vhost.DCL new file mode 100644 index 0000000000000000000000000000000000000000..130f616d802eb137b7a6eb7c9e2900bb930891e7 GIT binary patch literal 209 zcmYj}yAFad6owC1jkxIpu(=o%VuGV4j=H$$Mp{mxg({{Ld;lNEm$Zb%xG-3HZEeeuy zhXVLt3LZ!b{%UQ=aZ6|cSME*0>Ra!Y%7C!E1}sBMu{g>o06RVf^~;umAD;j~rmAF@3fC=$Hn|hsi0BQ()pKP|xu{ach>p za87}o0yzb83gi^XiUOtk0BFoM&}@LO#L8Jc_prw;;GXfZBQUSRD*$Ul-b1Sce11rK z)^yXZ06cvN&)2p9PNqDka2?=tDfL;;TaI6P3E;`w_u`QL~F+9`l9Ww;*NJpkXv z@e4NqHrU^*0C$h@JPmzG4~+1=aJ%}j{qN%7zXuy-F8iUaMh#Oe9p51${Nd-W76|{xRUSKUH+-waShVJL7jj) z0e0FZ9iMlvdDOt6^}cCUNf3BeGYqKDUYm^^kY)!TIB)oY7a9Q{c`5X%r*}QKOT9qO zd1>1ttz_k#;kwUR_|SIIslYe?aQdT*zxeHjQz<iL%I;I}oR z5!l%oGeZ?_i1ojwuK!}RR{Cz+^#ewT274XB1xh2YKU%y{vB{2$jBz2p;s;`oGN%KZ zYJxuyGmE>H7lg=Wj8q7bj%8bcZ$ibU0WnEH_Q@~}KX8$c=x|2*$z5lz2u9lCd^8#( zXNP8|hNGiJ$^4>t}9Xe$E$3o8ECWBAum z$Jv(8^iWb14Cpo!QbCviJ=&zm1*R{!p}^G#7H(296UeWbf0vMd`;#MJU5tZ6^D(ld zz##poJa*x_ z*#BKs_5Z5CzZv3(4%Iyucf?8UpW10AkYDEXNQe7;6I~H#=i}ycmvlm!iKhSCKU)&q zj~@iwg{xxyKTy|SZt+vsU1^N1ca1x1sHyk+gc$1#@N;nb#N9=_VjMo94EzAMd)?RH z|D9a-*KUl#!qe)){x7TRe^TJzr?#aJ6#|2M=A6N}o_X;OLn5qv?`M)T-W~^MOt4bR zUwzLM(2fiI*HrvV)$UQ|fxdg#<|Pxyxs{Y$dXVMu|OH{Xy_;9~Cd+cOMi zwxd=S_TMKe{-tA&o;TXW!C(Y>w=L31?f?dKi^+hL_~4Y-f=db7uu1o$Uxds`4n4o$ z$l=}sL6@HR(^cW-|Mb73ScC;VHy36X|Mv*}e>xrik?RU0;#7Aq>^=zpiEc6cPye29 zDP{5rIe<~(g&qx2N>CFes^Nw#C!sFPf~cH{v)~)m6Fm`eeH0Nfv+$Vui5ET;`u{x@ z|CN@lx6s+qO(MS65X1QN>Ud?g{h$`gU1sUvPT!_>6E{qm!1!0c`O!6*@-dRiP9|Tm zC6w=;S%%TnLujHWsGSn}e?!H;^yFJ1p~ubV{wpnfszr&tGlAs;sEu<+2) zj0ROCRZ@^%>t)N9qU6|lK}t-GCSl;}xS65>rWIFYav|;!h}Q~j%v8o~!3E#&NPyYc z_<64Db}R!^29{X5F~RguUDi}hmdDJhu;0Af4KPV78|&kzKX#=wxtL3np`e@$>B-dC)1>1XJ;&8tEw|DP7{M z)g&!0Yi}MlnG)8j#b}bEP0)c<_1(}jXp}ovGpQd~4q@UR6%Fc*F$jH5O7`#~4fx@g z0xK-@b2fN{#t1!+I!q0f@Ei=?;YwUR-E!&4Ycl$jJC!F$3*@gls}#_V75Tks+MFt? z<*wdCAGKxUStNoY7wuJ#3x@b%u)#f<^bp4H^zH!~{S-=(-%P0Tq~8ov0{{KaKcvF` za&Dl{Dxmi{Z|#b(|KC^fFY|xo{{Q)qhJDe$)J`*j`U0mdVV$4#9T(j2rtU|AJ%a@tOuZzl^C_JUN>;4EGbvV>~AsOYs<# z{eUnh#IeYqpo`wG?=%HT`fRO&ZzspGawfM z{J8s}i-5(-Q&I$6+^+~IMi)t>T}06?HUZ`?H=zuTCd|Eh4R2b|>MAH?wp%RJ!!kJ- zPsJ_b0o`Iinf`ECJSm3JC`C`AO&le~uy%wa%P-Qc2#$NdUSn@ba%Z1?SlY&~jp)pp zdR355a0V%$4a)zsEzfgNJL-Pe)s42*G5szz`b1rNx0w=k>w{^Ki2kD&H}V41qpz^b zK)A8L&?9grR`br~m!-;lHJ5%fi1K{OIR$bGycKU(