Simple Async Message Queue Server

A simple implementation of an ESB / Kafka

Implementation is done as part of a school project

Server Example

from simple_async_mq_server import server

db_config = {
    'host': 'localhost',
    'user': 'root',
    'password': '1234',
    'database': 'siasmq'
}

server.start(port=10000, db_config=db_config)

Currently supported transformations

Object and array definitions for each type can be found below.

Object and array definitions

JSON object:

{"person": 
  {"name": "john", "age": "20"}
}

JSON array:

  [
    {"name": "john", "age": "20"},
    {"name": "john", "age": "20"}
  ]

XML object:

<?xml version="1.0" ?>
<person>
  <name>John Johnson</name>
  <age>20</age>
</person>

XML array:

<?xml version="1.0" ?>
<persons>
  <person>
    <name>Daryl Dixon</name>
    <age>33</age>
  </person>
  <person>
    <name>Rick Grimes</name>
    <age>35</age>
 </person>
</persons>

CSV object:

a,b,c\n1,2,3

TSV object:

a\tb\tc\n1\t2\t3