diff --git a/CMakeLists.txt b/CMakeLists.txt
index 5367af20..f8e46e5c 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -34,19 +34,11 @@ add_subdirectory( LatencyTest )
 
 install(DIRECTORY ${CMAKE_SOURCE_DIR}/MiscATS/
         DESTINATION MiscATS
-        FILES_MATCHING PATTERN "*.db" PATTERN "*.sh" PATTERN "*.ini" PATTERN "*.cfg")
-
-install(CODE "
-    file(GLOB_RECURSE SCRIPT_FILES
-        \"\${CMAKE_INSTALL_PREFIX}/MiscATS/*.sh\")
-    foreach(script \${SCRIPT_FILES})
-        execute_process(COMMAND chmod +x \${script})
-    endforeach()
-")
-
-install(FILES 	FIXGateway/scripts/fixgateway.sh 
-		DataService/scripts/dataservice.sh 
-		MatchingEngine/scripts/matchingengine.sh 
+        FILES_MATCHING PATTERN "*.db" PATTERN "*.py" PATTERN "*.ini" PATTERN "*.cfg" PATTERN "*.json")
+
+install(FILES 	FIXGateway/scripts/fix_gateway_manager.py 
+		DataService/scripts/data_service_manager.py
+		MatchingEngine/scripts/matching_engine_manager.py
 		DESTINATION scripts
    		PERMISSIONS OWNER_READ OWNER_WRITE OWNER_EXECUTE
                 GROUP_READ GROUP_EXECUTE
diff --git a/DataService/scripts/data_service_manager.py b/DataService/scripts/data_service_manager.py
new file mode 100644
index 00000000..3ea05653
--- /dev/null
+++ b/DataService/scripts/data_service_manager.py
@@ -0,0 +1,107 @@
+#!/usr/bin/env python3
+
+import os
+import sys
+import time
+import subprocess
+from pathlib import Path
+import psutil
+
+PROGNAME = "DataService"
+
+
+def get_config_file():
+    if len(sys.argv) < 3:
+        print(f"Usage: {sys.argv[0]} [start|stop|check] <config_file>")
+        sys.exit(1)
+    return sys.argv[2]
+
+
+def get_paths(config_file):
+    basedir = os.environ.get("BASEDIR_ATS", ".")
+    dats_home = os.environ.get("DATS_HOME")
+    if not dats_home:
+        print("DATS_HOME is not set.")
+        sys.exit(1)
+
+    config_path = Path(basedir) / "config" / config_file
+    log_path = Path(basedir) / "logs" / f"{PROGNAME}.{config_file}.console.log"
+    binary_path = Path(dats_home) / "bin" / PROGNAME
+    return binary_path, config_path, log_path, basedir
+
+
+def source_dats_env():
+    dats_home = os.environ.get("DATS_HOME")
+    env_script = Path(dats_home) / "dats_env.sh"
+    if env_script.exists():
+        subprocess.call(f"source {env_script}", shell=True, executable="/bin/bash")
+
+
+def check_process(config_path):
+    for proc in psutil.process_iter(['pid', 'cmdline']):
+        try:
+            cmdline = proc.info['cmdline']
+            if cmdline and PROGNAME in cmdline[0] and str(config_path) in ' '.join(cmdline):
+                print(f"{PROGNAME} [{config_path.name}] is running - {proc.pid}")
+                return proc.pid
+        except (psutil.NoSuchProcess, psutil.AccessDenied, psutil.ZombieProcess):
+            continue
+    print(f"{PROGNAME} [{config_path.name}] is not running")
+    return None
+
+
+def start_process(binary_path, config_path, log_path):
+    print(f"Starting: {PROGNAME} -c {config_path}")
+    for key in sorted(os.environ):
+        print(f"{key}={os.environ[key]}")
+    if check_process(config_path) is None:
+        with open(log_path, "a") as f:
+            subprocess.Popen([str(binary_path), "-c", str(config_path)],
+                             stdout=f, stderr=subprocess.STDOUT)
+        time.sleep(1)
+        check_process(config_path)
+
+
+def stop_process(config_path):
+    cmd_str = f"{PROGNAME} -c {config_path}"
+    print(f"Stopping: {cmd_str}")
+    pid = check_process(config_path)
+    if pid:
+        os.system(f"pkill -SIGTERM -f \"{cmd_str}\"")
+        time.sleep(1)
+
+        for _ in range(10):
+            if check_process(config_path) is None:
+                break
+            time.sleep(1)
+        else:
+            os.system(f"pkill -KILL -U {os.getuid()} -f \"{cmd_str}\"")
+
+
+def main():
+    if len(sys.argv) < 3:
+        print(f"Usage: {sys.argv[0]} [start|stop|check] <config_file>")
+        sys.exit(1)
+
+    command = sys.argv[1].lower()
+    config_file = get_config_file()
+
+    binary_path, config_path, log_path, basedir = get_paths(config_file)
+    source_dats_env()
+
+    if command == "start":
+        start_process(binary_path, config_path, log_path)
+    elif command == "stop":
+        stop_process(config_path)
+    elif command == "check":
+        check_process(config_path)
+    else:
+        print("Unknown command")
+        sys.exit(1)
+
+    with open(log_path, "a") as f:
+        f.write(f"{time.strftime('%Y%m%d.%H%M%S')} run-done : pid,{os.getpid()}\n")
+
+
+if __name__ == "__main__":
+    main()
diff --git a/DataService/src/MarketDataService.cpp b/DataService/src/MarketDataService.cpp
index 6e199628..6a7f3818 100644
--- a/DataService/src/MarketDataService.cpp
+++ b/DataService/src/MarketDataService.cpp
@@ -209,6 +209,8 @@ int MarketDataService::service (void)
             std::this_thread::sleep_for(std::chrono::duration<long double, std::milli>(1000));
         }
     };
+    
+    return 0;
 }
 
 bool MarketDataService::populateMarketDataSnapshotFullRefresh( const Instrument& instrument,
diff --git a/DataService/src/RefDataService.cpp b/DataService/src/RefDataService.cpp
index e85fc3be..02fecf10 100644
--- a/DataService/src/RefDataService.cpp
+++ b/DataService/src/RefDataService.cpp
@@ -94,7 +94,8 @@ void RefDataService::populateUserGroupInstrumentMap()
                                " m.market_name=im_map.market_name and " \
                                " im_map.market_name=ugm_map.market_name");
 
-    LOG4CXX_INFO(logger, "Populating security list");
+    LOG4CXX_INFO(logger, "Populating security list : ");
+    LOG4CXX_INFO(logger, "Query : " + sqliteQuery.getQuery());
         
     m_sqliteConnection->execute(sqliteQuery);
         
diff --git a/DataService/src/SQLiteConnection.hpp b/DataService/src/SQLiteConnection.hpp
index 187d8667..32a1ef1e 100644
--- a/DataService/src/SQLiteConnection.hpp
+++ b/DataService/src/SQLiteConnection.hpp
@@ -42,8 +42,6 @@ class SQLiteQuery
 public:
     SQLiteQuery( const std::string& query ) : m_stmt(0), m_query( query )
   {
-      
-      std::cout << query << std::endl;
   }
 
   ~SQLiteQuery()
@@ -95,6 +93,11 @@ class SQLiteQuery
   {
       return m_rows[row][column];
   }
+    
+  std::string getQuery()
+  {
+      return m_query;
+  }
 
 private:
   sqlite3_stmt* m_stmt;
diff --git a/FIXGateway/scripts/fix_gateway_manager.py b/FIXGateway/scripts/fix_gateway_manager.py
new file mode 100644
index 00000000..a137a7a2
--- /dev/null
+++ b/FIXGateway/scripts/fix_gateway_manager.py
@@ -0,0 +1,98 @@
+#!/usr/bin/env python3
+
+import os
+import sys
+import time
+import subprocess
+from pathlib import Path
+import psutil
+
+PROGNAME = "FIXGateway"
+
+
+def usage():
+    print(f"Usage: {sys.argv[0]} [start|stop|check] <config_file>")
+    sys.exit(1)
+
+
+def get_paths(config_file):
+    basedir = os.environ.get("BASEDIR_ATS", ".")
+    dats_home = os.environ.get("DATS_HOME")
+    if not dats_home:
+        print("DATS_HOME is not set.")
+        sys.exit(1)
+
+    config_path = Path(basedir) / "config" / config_file
+    log_path = Path(basedir) / "logs" / f"{PROGNAME}.{config_file}.console.log"
+    binary_path = Path(dats_home) / "bin" / PROGNAME
+    return binary_path, config_path, log_path
+
+
+def check_process(config_path):
+    for proc in psutil.process_iter(['pid', 'cmdline']):
+        try:
+            cmdline = proc.info['cmdline']
+            if cmdline and PROGNAME in cmdline[0] and str(config_path) in ' '.join(cmdline):
+                print(f"{PROGNAME} [{config_path.name}] is running - {proc.pid}")
+                return proc.pid
+        except (psutil.NoSuchProcess, psutil.AccessDenied, psutil.ZombieProcess):
+            continue
+    print(f"{PROGNAME} [{config_path.name}] is not running")
+    return None
+
+
+def start_process(binary_path, config_path, log_path):
+    process_str = f"{PROGNAME} -c {config_path}"
+    print(f"Starting: {process_str}")
+    for key in sorted(os.environ):
+        print(f"{key}={os.environ[key]}")
+    if check_process(config_path) is None:
+        with open(log_path, "a") as f:
+            subprocess.Popen([str(binary_path), "-c", str(config_path)],
+                             stdout=f, stderr=subprocess.STDOUT)
+        time.sleep(1)
+        check_process(config_path)
+
+
+def stop_process(config_path):
+    process_str = f"{PROGNAME} -c {config_path}"
+    print(f"Stopping: {process_str}")
+    pid = check_process(config_path)
+    if pid:
+        os.system(f"pkill -SIGTERM -f \"{process_str}\"")
+        time.sleep(1)
+
+        # Try up to 10 seconds to let it exit
+        for _ in range(10):
+            if check_process(config_path) is None:
+                break
+            time.sleep(1)
+        else:
+            os.system(f"pkill -KILL -U {os.getuid()} -f \"{process_str}\"")
+
+
+def main():
+    if len(sys.argv) < 3:
+        usage()
+
+    command = sys.argv[1].lower()
+    config_file = sys.argv[2]
+
+    binary_path, config_path, log_path = get_paths(config_file)
+
+    if command == "start":
+        start_process(binary_path, config_path, log_path)
+    elif command == "stop":
+        stop_process(config_path)
+    elif command == "check":
+        check_process(config_path)
+    else:
+        usage()
+
+    # Final run log
+    with open(log_path, "a") as f:
+        f.write(f"{time.strftime('%Y%m%d.%H%M%S')} run-done : pid,{os.getpid()}\n")
+
+
+if __name__ == "__main__":
+    main()
diff --git a/MatchingEngine/scripts/matching_engine_manager.py b/MatchingEngine/scripts/matching_engine_manager.py
new file mode 100644
index 00000000..e8e22370
--- /dev/null
+++ b/MatchingEngine/scripts/matching_engine_manager.py
@@ -0,0 +1,107 @@
+#!/usr/bin/env python3
+
+import os
+import sys
+import time
+import subprocess
+from pathlib import Path
+import psutil
+
+PROGNAME = "MatchingEngine"
+
+def get_config_file():
+    if len(sys.argv) < 3:
+        print(f"Usage: {sys.argv[0]} [start|stop|check] <config_file>")
+        sys.exit(1)
+    return sys.argv[2]
+
+
+def get_paths(config_file):
+    basedir = os.environ.get("BASEDIR_ATS", ".")
+    dats_home = os.environ.get("DATS_HOME")
+    if not dats_home:
+        print("DATS_HOME is not set.")
+        sys.exit(1)
+
+    config_path = Path(basedir) / "config" / config_file
+    log_path = Path(basedir) / "logs" / f"{PROGNAME}.{config_file}.console.log"
+    binary_path = Path(dats_home) / "bin" / PROGNAME
+    return binary_path, config_path, log_path, basedir
+
+
+def source_dats_env():
+    dats_home = os.environ.get("DATS_HOME")
+    env_script = Path(dats_home) / "dats_env.sh"
+    if env_script.exists():
+        subprocess.call(f"source {env_script}", shell=True, executable="/bin/bash")
+
+
+def check_process(config_path):
+    for proc in psutil.process_iter(['pid', 'cmdline']):
+        try:
+            cmdline = proc.info['cmdline']
+            if cmdline and PROGNAME in cmdline[0] and str(config_path) in ' '.join(cmdline):
+                print(f"{PROGNAME} [{config_path.name}] is running - {proc.pid}")
+                return proc.pid
+        except (psutil.NoSuchProcess, psutil.AccessDenied, psutil.ZombieProcess):
+            continue
+    print(f"{PROGNAME} [{config_path.name}] is not running")
+    return None
+
+
+def start_process(binary_path, config_path, log_path):
+    print(f"Starting: {PROGNAME} -c {config_path}")
+    for key in sorted(os.environ):
+        print(f"{key}={os.environ[key]}")
+    if check_process(config_path) is None:
+        with open(log_path, "a") as f:
+            subprocess.Popen([str(binary_path), "-c", str(config_path)],
+                             stdout=f, stderr=subprocess.STDOUT)
+        time.sleep(1)
+        check_process(config_path)
+
+
+def stop_process(config_path):
+    cmd_str = f"{PROGNAME} -c {config_path}"
+    print(f"Stopping: {cmd_str}")
+    pid = check_process(config_path)
+    if pid:
+        os.system(f"pkill -SIGTERM -f \"{cmd_str}\"")
+        time.sleep(1)
+
+        for _ in range(10):
+            if check_process(config_path) is None:
+                break
+            time.sleep(1)
+        else:
+            os.system(f"pkill -KILL -U {os.getuid()} -f \"{cmd_str}\"")
+
+
+def main():
+    if len(sys.argv) < 3:
+        print(f"Usage: {sys.argv[0]} [start|stop|check] <config_file>")
+        sys.exit(1)
+
+    command = sys.argv[1].lower()
+    config_file = get_config_file()
+
+    binary_path, config_path, log_path, basedir = get_paths(config_file)
+
+    source_dats_env()
+
+    if command == "start":
+        start_process(binary_path, config_path, log_path)
+    elif command == "stop":
+        stop_process(config_path)
+    elif command == "check":
+        check_process(config_path)
+    else:
+        print("Unknown command")
+        sys.exit(1)
+
+    with open(log_path, "a") as f:
+        f.write(f"{time.strftime('%Y%m%d.%H%M%S')} run-done : pid,{os.getpid()}\n")
+
+
+if __name__ == "__main__":
+    main()
diff --git a/MatchingEngine/src/Market.cpp b/MatchingEngine/src/Market.cpp
index 1414dd45..eb2fa1e7 100644
--- a/MatchingEngine/src/Market.cpp
+++ b/MatchingEngine/src/Market.cpp
@@ -54,7 +54,7 @@ Market::Market(DataWriterContainerPtr dataWriterContainerPtr,
                PriceDepthPublisherQueuePtr&
                price_depth_publisher_queue_ptr)
     : dataWriterContainerPtr_(dataWriterContainerPtr), _marketName(marketName), _dataServiceName(dataServiceName),
-    _price_depth_publisher_queue_ptr( price_depth_publisher_queue_ptr )
+_price_depth_publisher_queue_ptr( price_depth_publisher_queue_ptr ), _ready_to_trade(false)
 {
   stats_ptr_ = std::make_shared<OrderBookStatsMap>();
 }
diff --git a/MatchingEngine/src/Market.h b/MatchingEngine/src/Market.h
index 93e98c83..24ddf999 100644
--- a/MatchingEngine/src/Market.h
+++ b/MatchingEngine/src/Market.h
@@ -168,7 +168,8 @@ class Market : public liquibook::book::OrderListener<OrderPtr>,
 
   OrderBookPtr addBook(const std::string &symbol, bool useDepthBook);
                    
-  bool is_ready_to_trade() { return (books_.size() > 0); };
+  bool get_ready_to_trade() { return _ready_to_trade.load(); };
+  void set_ready_to_trade( bool ready_to_trade ) { _ready_to_trade.store(ready_to_trade); };
 
 public:
                    
@@ -216,6 +217,8 @@ class Market : public liquibook::book::OrderListener<OrderPtr>,
   std::string _marketName; // Quickfix field 207 - Security Exchange
   std::string _dataServiceName;
                    
+  std::atomic<bool> _ready_to_trade;
+                   
 };
 
 typedef std::shared_ptr<Market> market_ptr;
diff --git a/MatchingEngine/src/SecurityListDataReaderListenerImpl.cpp b/MatchingEngine/src/SecurityListDataReaderListenerImpl.cpp
index 3dd30ca6..66f379ed 100644
--- a/MatchingEngine/src/SecurityListDataReaderListenerImpl.cpp
+++ b/MatchingEngine/src/SecurityListDataReaderListenerImpl.cpp
@@ -51,7 +51,7 @@ void SecurityListDataReaderListenerImpl::on_data_available(
     DistributedATS_SecurityList::SecurityList security_list;
     eprosima::fastdds::dds::SampleInfo info;
     
-    if (_marketPtr->is_ready_to_trade())
+    if (_marketPtr->get_ready_to_trade() == true)
         return;
     
     if (reader->take_next_sample(&security_list, &info) == eprosima::fastdds::dds::RETCODE_OK)
@@ -59,12 +59,16 @@ void SecurityListDataReaderListenerImpl::on_data_available(
         std::stringstream ss;
         SecurityListLogger::log(ss, security_list);
         LOG4CXX_INFO(logger, "SecurityList : [" <<  ss.str() << "]");
+        
+        std::cout << "Security:" << ss.str() << std::endl;
             
         for (uint32_t sec_index = 0; sec_index < security_list.c_NoRelatedSym().size(); sec_index++)
         {
             std::string instrument = security_list.c_NoRelatedSym()[sec_index].Symbol();
             _marketPtr->addBook(instrument, true);
         }
+        
+        _marketPtr->set_ready_to_trade(true);
             
         // request to recieve opening price
         _marketPtr->publishMarketDataRequest();
diff --git a/MatchingEngine/src/SecurityListRequestDataWriterListener.h b/MatchingEngine/src/SecurityListRequestDataWriterListener.h
index de154b56..9afbb0fe 100644
--- a/MatchingEngine/src/SecurityListRequestDataWriterListener.h
+++ b/MatchingEngine/src/SecurityListRequestDataWriterListener.h
@@ -1,3 +1,9 @@
+#include <thread>
+#include <atomic>
+#include <iostream>
+#include <chrono>
+#include <mutex>
+
 #pragma once
 
 namespace DistributedATS
@@ -5,44 +11,55 @@ namespace DistributedATS
 
 class SecurityListRequestDataWriterListener : public eprosima::fastdds::dds::DataWriterListener
 {
-    
-    public:
+public:
 
-    SecurityListRequestDataWriterListener( const market_ptr& marketPtr ) : matched_(0), _market_ptr(marketPtr)
+    SecurityListRequestDataWriterListener(const market_ptr& marketPtr)
+        : matched_(0), _market_ptr(marketPtr), thread_started_(false)
     {
     }
 
-    ~SecurityListRequestDataWriterListener() override
-    {
-    }
+    ~SecurityListRequestDataWriterListener() override = default;
 
     void on_publication_matched(
-                            eprosima::fastdds::dds::DataWriter* dwr,
-                            const eprosima::fastdds::dds::PublicationMatchedStatus& info) override
+        eprosima::fastdds::dds::DataWriter* dwr,
+        const eprosima::fastdds::dds::PublicationMatchedStatus& info) override
     {
-        if (info.current_count_change >= 1)
+        if (info.current_count_change > 0)
         {
             matched_ = info.total_count;
-            LOG4CXX_INFO(logger, "SecurityListRequestDataWriterListener Publisher Matched:" << matched_);
-            if ( !_market_ptr->is_ready_to_trade() )
-                _market_ptr->publishSecurityListRequest(dwr);
+            //std::cout << "[Listener] Publisher Matched: " << matched_ << std::endl;
+
+            // Start thread only once
+            bool expected = false;
+            if (thread_started_.compare_exchange_strong(expected, true))
+            {
+                std::thread([this, dwr]() {
+                    while (!_market_ptr->get_ready_to_trade())
+                    {
+                        //std::cout << "[Listener] Publishing Security Lise Exchange " << matched_ << std::endl;
+                        _market_ptr->publishSecurityListRequest(dwr);
+                        std::this_thread::sleep_for(std::chrono::seconds(1));
+                    }
+                }).detach();
+            }
         }
         else if (info.current_count_change == -1)
         {
             matched_ = info.total_count;
-            LOG4CXX_INFO(logger, "SecurityListRequestDataWriterListener Publisher UnMatched:" << matched_);
+            std::cout << "[Listener] Publisher UnMatched: " << matched_ << std::endl;
         }
         else
         {
-            LOG4CXX_INFO(logger, "Is not a valid value for PublicationMatchedStatus current count change." << info.current_count_change);
+            std::cout << "[Listener] Invalid current_count_change: " << info.current_count_change << std::endl;
         }
     }
 
-    private:
-        market_ptr _market_ptr;
-        std::atomic_int matched_;
-    };
+private:
+    market_ptr _market_ptr;
+    std::atomic_int matched_;
+    std::atomic<bool> thread_started_;  // <--- Ensures thread is only started once
+};
 
 using security_list_request_data_writer_listener_ptr = std::unique_ptr<SecurityListRequestDataWriterListener>;
 
-};
+}; // namespace DistributedATS
diff --git a/MiscATS/CryptoCLOB/crypto_ats.json b/MiscATS/CryptoCLOB/crypto_ats.json
new file mode 100644
index 00000000..3aa71ae8
--- /dev/null
+++ b/MiscATS/CryptoCLOB/crypto_ats.json
@@ -0,0 +1,10 @@
+[
+  ["data_service_manager.py", "data_service_a.ini"],
+  ["data_service_manager.py", "data_service_b.ini"],
+  ["matching_engine_manager.py", "matching_engine_MARKET_BTC.ini"],
+  ["matching_engine_manager.py", "matching_engine_MARKET_ETH.ini"],
+  ["matching_engine_manager.py", "matching_engine_MARKET_OTHER_COIN.ini"],
+  ["fix_gateway_manager.py", "fix_gwy_1.cfg"],
+  ["fix_gateway_manager.py", "fix_gwy_2.cfg"],
+  ["fix_gateway_manager.py", "fix_gwy_3.cfg"]
+]
\ No newline at end of file
diff --git a/MiscATS/CryptoCLOB/data/distributed_ats.db b/MiscATS/CryptoCLOB/data/distributed_ats.db
index 440cc49b..366d8143 100644
Binary files a/MiscATS/CryptoCLOB/data/distributed_ats.db and b/MiscATS/CryptoCLOB/data/distributed_ats.db differ
diff --git a/MiscATS/CryptoCLOB/scripts/start_ats.sh b/MiscATS/CryptoCLOB/scripts/start_ats.sh
deleted file mode 100755
index aae85eec..00000000
--- a/MiscATS/CryptoCLOB/scripts/start_ats.sh
+++ /dev/null
@@ -1,51 +0,0 @@
-#!/bin/bash
-
-trap cleanup 1 2 3 6
-
-cleanup()
-{
-	echo "Caught Signal ... cleaning up..."
-
-	$BASEDIR_ATS/scripts/stop_ats.sh
-
-	echo "Done."
-
-	exit 1;
-}
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_a.ini
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_BTC.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_ETH.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_OTHER_COIN.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_1.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_2.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_3.cfg
-
-while true; do 
-	$DATS_HOME/scripts/dataservice.sh check data_service_a.ini
-	$DATS_HOME/scripts/dataservice.sh check data_service_b.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_BTC.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_ETH.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_OTHER_COIN.ini
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_1.cfg
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_2.cfg
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_3.cfg
-
-	sleep 2;
-done
diff --git a/MiscATS/CryptoCLOB/scripts/stop_ats.sh b/MiscATS/CryptoCLOB/scripts/stop_ats.sh
deleted file mode 100755
index a439ae62..00000000
--- a/MiscATS/CryptoCLOB/scripts/stop_ats.sh
+++ /dev/null
@@ -1,26 +0,0 @@
-#!/bin/sh
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh stop data_service_a.ini 
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh stop data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh stop matching_engine_MARKET_BTC.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh stop matching_engine_MARKET_ETH.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh stop matching_engine_MARKET_OTHER_COIN.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_1.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_2.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_3.cfg
-
diff --git a/MiscATS/CryptoCLOB/sql/populate_db.sh b/MiscATS/CryptoCLOB/sql/populate_db.sh
index c60e78fd..4c3b259b 100755
--- a/MiscATS/CryptoCLOB/sql/populate_db.sh
+++ b/MiscATS/CryptoCLOB/sql/populate_db.sh
@@ -1,6 +1,7 @@
 #!/bin/sh
 
-$SQLITE_HOME/bin/sqlite3 $DATS_HOME/DataService/sql/sqlite/distributed_ats.db <<EOF
+#$SQLITE_HOME/bin/sqlite3 $DATS_HOME/DataService/sql/sqlite/distributed_ats.db <<EOF
+$SQLITE_HOME/bin/sqlite3 distributed_ats.db <<EOF
 
 PRAGMA foreign_keys = ON;
 
@@ -21,9 +22,9 @@ update user_code set properties=json_set(properties, '$.password','TEST') where
 replace into user_code ( user_name, user_group, properties ) values ('CRYPTO_TRADER_4', 'CRYPTO_TRADER_GROUP_C', '{"name":"CRYPTO TRADER 4","type":"TRADER"}');
 update user_code set properties=json_set(properties, '$.password','TEST') where user_name='CRYPTO_TRADER_4';
 
-replace into market ( market_name, properties ) values ('BTC_MARKET', "{}");
-replace into market ( market_name, properties ) values ('ETH_MARKET', "{}");
-replace into market ( market_name, properties ) values ('OTHER_COIN_MARKET', "{}");
+replace into market ( market_name, properties ) values ('BTC_MARKET', '{}');
+replace into market ( market_name, properties ) values ('ETH_MARKET', '{}');
+replace into market ( market_name, properties ) values ('OTHER_COIN_MARKET', '{}');
 
 
 replace into user_group_market_map ( user_group, market_name ) values ('CRYPTO_TRADER_GROUP_A','BTC_MARKET');
@@ -63,13 +64,13 @@ replace into instrument_market_map ( instrument_name, market_name ) values ('BTC
 replace into instrument_market_map ( instrument_name, market_name ) values ('BTC-CNY','BTC_MARKET');
 replace into instrument_market_map ( instrument_name, market_name ) values ('BTC-JPY','BTC_MARKET');
 
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-USD", 20210401, '{"open":10100,"low":10000,"high":20000,"last":15000, "volume":10000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-EUR", 20210401, '{"open":20100,"low":20000,"high":30000,"last":25000, "volume":20000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-GBP", 20210401, '{"open":30100,"low":30000,"high":40000,"last":35000, "volume":30000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-AUD", 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":40000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-CAD", 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":50000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-CNY", 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":60000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("BTC-JPY", 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":70000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-USD', 20210401, '{"open":10100,"low":10000,"high":20000,"last":15000, "volume":10000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-EUR', 20210401, '{"open":20100,"low":20000,"high":30000,"last":25000, "volume":20000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-GBP', 20210401, '{"open":30100,"low":30000,"high":40000,"last":35000, "volume":30000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-AUD', 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":40000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-CAD', 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":50000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-CNY', 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":60000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('BTC-JPY', 20210401, '{"open":40100,"low":40000,"high":50000,"last":45000, "volume":70000}');
 
 
 replace into instrument ( instrument_name, properties ) values ('ETH-USD', '{"type":"Crypto"}');
@@ -88,13 +89,13 @@ replace into instrument_market_map ( instrument_name, market_name ) values ('ETH
 replace into instrument_market_map ( instrument_name, market_name ) values ('ETH-CNY','ETH_MARKET');
 replace into instrument_market_map ( instrument_name, market_name ) values ('ETH-JPY','ETH_MARKET');
 
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-USD", 20210401, '{"open":1010,"low":1000,"high":2000,"last":1500, "volume":100000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-EUR", 20210401, '{"open":2010,"low":2000,"high":3000,"last":2500, "volume":200000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-GBP", 20210401, '{"open":3010,"low":3000,"high":4000,"last":3500, "volume":300000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-AUD", 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":400000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-CAD", 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":500000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-CNY", 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":600000}');
-replace into hist_price ( instrument_name, business_date, properties ) values ("ETH-JPY", 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":700000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-USD', 20210401, '{"open":1010,"low":1000,"high":2000,"last":1500, "volume":100000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-EUR', 20210401, '{"open":2010,"low":2000,"high":3000,"last":2500, "volume":200000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-GBP', 20210401, '{"open":3010,"low":3000,"high":4000,"last":3500, "volume":300000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-AUD', 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":400000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-CAD', 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":500000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-CNY', 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":600000}');
+replace into hist_price ( instrument_name, business_date, properties ) values ('ETH-JPY', 20210401, '{"open":4010,"low":4000,"high":5000,"last":4500, "volume":700000}');
 
 
 replace into instrument ( instrument_name, properties ) values ('ADA-USD', '{"type":"Crypto"}');
diff --git a/MiscATS/MultiMatchingEngineATS/multi_matching_engine.json b/MiscATS/MultiMatchingEngineATS/multi_matching_engine.json
new file mode 100644
index 00000000..b188ad4a
--- /dev/null
+++ b/MiscATS/MultiMatchingEngineATS/multi_matching_engine.json
@@ -0,0 +1,9 @@
+[
+  ["data_service_manager.py", "data_service_a.ini"],
+  ["data_service_manager.py", "data_service_b.ini"],
+  ["matching_engine_manager.py", "matching_engine_MARKET_Y.ini"],
+  ["matching_engine_manager.py", "matching_engine_MARKET_Z.ini"],
+  ["fix_gateway_manager.py", "fix_gwy_1.cfg"],
+  ["fix_gateway_manager.py", "fix_gwy_2.cfg"],
+  ["fix_gateway_manager.py", "fix_gwy_3.cfg"]
+]
diff --git a/MiscATS/MultiMatchingEngineATS/scripts/start_ats.sh b/MiscATS/MultiMatchingEngineATS/scripts/start_ats.sh
deleted file mode 100755
index 2a9f23e4..00000000
--- a/MiscATS/MultiMatchingEngineATS/scripts/start_ats.sh
+++ /dev/null
@@ -1,47 +0,0 @@
-#!/bin/bash
-
-trap cleanup 1 2 3 6
-
-cleanup()
-{
-	echo "Caught Signal ... cleaning up..."
-
-	$BASEDIR_ATS/scripts/stop_ats.sh
-
-	echo "Done."
-
-	exit 1;
-}
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_a.ini
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_Y.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_Z.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_1.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_2.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_3.cfg
-
-while true; do 
-	$DATS_HOME/scripts/dataservice.sh check data_service_a.ini
-	$DATS_HOME/scripts/dataservice.sh check data_service_b.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_Y.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_Z.ini
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_1.cfg
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_2.cfg
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_3.cfg
-
-	sleep 2;
-done
diff --git a/MiscATS/MultiMatchingEngineATS/scripts/stop_ats.sh b/MiscATS/MultiMatchingEngineATS/scripts/stop_ats.sh
deleted file mode 100755
index 018e9868..00000000
--- a/MiscATS/MultiMatchingEngineATS/scripts/stop_ats.sh
+++ /dev/null
@@ -1,22 +0,0 @@
-#!/bin/sh
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh stop data_service_a.ini 
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh stop data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh stop matching_engine_MARKET_Y.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh stop matching_engine_MARKET_Z.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_1.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_2.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_3.cfg
diff --git a/MiscATS/USTreasuryCLOB/scripts/start_ats.sh b/MiscATS/USTreasuryCLOB/scripts/start_ats.sh
deleted file mode 100755
index 808f6694..00000000
--- a/MiscATS/USTreasuryCLOB/scripts/start_ats.sh
+++ /dev/null
@@ -1,39 +0,0 @@
-#!/bin/bash
-
-trap cleanup 1 2 3 6
-
-cleanup()
-{
-	echo "Caught Signal ... cleaning up..."
-
-	$BASEDIR_ATS/scripts/stop_ats.sh
-
-	echo "Done."
-
-	exit 1;
-}
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_a.ini
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_UST.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_1.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_2.cfg
-
-while true; do 
-	$DATS_HOME/scripts/dataservice.sh check data_service_a.ini
-	$DATS_HOME/scripts/dataservice.sh check data_service_b.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_UST.ini
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_1.cfg
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_2.cfg
-
-	sleep 2;
-done
diff --git a/MiscATS/USTreasuryCLOB/scripts/stop_ats.sh b/MiscATS/USTreasuryCLOB/scripts/stop_ats.sh
deleted file mode 100755
index 35caf690..00000000
--- a/MiscATS/USTreasuryCLOB/scripts/stop_ats.sh
+++ /dev/null
@@ -1,16 +0,0 @@
-#!/bin/sh
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh stop data_service_a.ini 
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh stop data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/matchingengine.sh stop matching_engine_MARKET_UST.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_1.cfg
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh stop fix_gwy_2.cfg
diff --git a/MiscATS/USTreasuryCLOB/ust_ats.json b/MiscATS/USTreasuryCLOB/ust_ats.json
new file mode 100644
index 00000000..c30dd9cd
--- /dev/null
+++ b/MiscATS/USTreasuryCLOB/ust_ats.json
@@ -0,0 +1,7 @@
+[
+  ["data_service_manager.py", "data_service_a.ini"],
+  ["data_service_manager.py", "data_service_b.ini"],
+  ["matching_engine_manager.py", "matching_engine_MARKET_UST.ini"],
+  ["fix_gateway_manager.py", "fix_gwy_1.cfg"],
+  ["fix_gateway_manager.py", "fix_gwy_2.cfg"]
+]
diff --git a/MiscATS/start_ats.py b/MiscATS/start_ats.py
new file mode 100644
index 00000000..6553e14f
--- /dev/null
+++ b/MiscATS/start_ats.py
@@ -0,0 +1,112 @@
+#!/usr/bin/env python3
+
+import subprocess
+import time
+import signal
+import sys
+import os
+import json
+import argparse
+from pathlib import Path
+
+# --- Environment Setup ---
+dats_home = os.environ.get("DATS_HOME")
+basedir_ats = os.environ.get("BASEDIR_ATS")
+
+dats_env = os.environ.copy()
+
+# --- Globals ---
+stop_script = None
+scripts_dir = None
+json_path_ats = None
+commands = []
+
+# --- Cleanup Handler ---
+def cleanup(signum=None, frame=None):
+    print("\nCaught signal... cleaning up.")
+    try:
+        subprocess.run(["python3", str(stop_script), '--ats', str(json_path_ats)], check=False)
+    except Exception as e:
+        print(f"Error running stop script: {e}")
+    print("Done.")
+    sys.exit(1)
+
+# --- Signal Registration ---
+def register_signals():
+    for sig in [signal.SIGINT, signal.SIGHUP, signal.SIGQUIT, signal.SIGABRT]:
+        signal.signal(sig, cleanup)
+
+# --- Load ATS Command List from JSON ---
+def load_commands():
+    try:
+        with open(json_path_ats) as f:
+            return [tuple(entry) for entry in json.load(f)]
+    except Exception as e:
+        print(f"Failed to load command list from {json_path_ats}: {e}")
+        sys.exit(1)
+
+# --- Start and Monitor Processes ---
+def run_services():
+
+    env_file = Path(dats_home) / "dats_env.sh"
+    scripts_dir = Path(dats_home) / "scripts"
+
+
+    for script, cfg in commands:
+        time.sleep(1)
+        print(f"Starting {script} {cfg}")
+        dats_env["LOG_FILE_NAME"] = f"{cfg}.log"
+        subprocess.Popen(
+            f"source {env_file} && python3 {scripts_dir / script} start {cfg}",
+            shell=True,
+            executable="/bin/bash",
+            env=dats_env
+        )
+
+    try:
+        while True:
+            for script, cfg in commands:
+                subprocess.run([str(scripts_dir / script), "check", cfg], check=False)
+            time.sleep(2)
+    except KeyboardInterrupt:
+        cleanup()
+
+# --- Main ---
+def main():
+    global stop_script, scripts_dir, json_path_ats, commands
+
+    parser = argparse.ArgumentParser(description="Start and monitor ATS components.")
+    parser.add_argument(
+        "--ats",
+        type=Path,
+        default=Path(__file__).resolve().parent / "ats.json",
+        help="Path to ATS command JSON file (default: ats.json in script directory)"
+    )
+
+    args = parser.parse_args()
+
+    # Validate env
+    dats_home = os.environ.get("DATS_HOME")
+    basedir_ats = os.environ.get("BASEDIR_ATS")
+
+    if not dats_home or not basedir_ats:
+        print("Error: DATS_HOME and BASEDIR_ATS environment variables must be set.")
+        sys.exit(1)
+
+    log_dir = Path(basedir_ats) / "logs"
+    log_dir.mkdir(exist_ok=True)
+    dats_env["DATS_LOG_HOME"] = str(log_dir)
+
+    stop_script = "stop_ats.py"
+
+    if not args.ats.exists():
+        print(f"ATS JSON file does not exist: {args.ats}")
+        sys.exit(1)
+
+    json_path_ats = args.ats
+    commands = load_commands()
+    register_signals()
+    run_services()
+
+if __name__ == "__main__":
+    main()
diff --git a/MiscATS/stop_ats.py b/MiscATS/stop_ats.py
new file mode 100644
index 00000000..b9da6ffc
--- /dev/null
+++ b/MiscATS/stop_ats.py
@@ -0,0 +1,58 @@
+#!/usr/bin/env python3
+
+import os
+import time
+import subprocess
+import argparse
+import json
+from pathlib import Path
+import sys
+
+def load_commands(json_path):
+    try:
+        with open(json_path) as f:
+            return [tuple(entry) for entry in json.load(f)]
+    except Exception as e:
+        print(f"Error loading JSON file '{json_path}': {e}")
+        sys.exit(1)
+
+def stop_services(commands, scripts_dir):
+    for script, config in commands:
+        time.sleep(1)
+        script_path = scripts_dir / script
+        if not script_path.exists():
+            print(f"Script not found: {script_path}")
+            continue
+        print(f"Stopping: {script} {config}")
+        try:
+            subprocess.run(["python3", str(script_path), "stop", config], check=False)
+        except Exception as e:
+            print(f"Failed to stop {script} with config {config}: {e}")
+
+def main():
+    parser = argparse.ArgumentParser(description="Stop ATS components from JSON list.")
+    parser.add_argument(
+        "--ats",
+        type=Path,
+        default=Path(__file__).resolve().parent / "ats_commands.json",
+        help="Path to ATS JSON config list (default: ats_commands.json in script directory)"
+    )
+
+    args = parser.parse_args()
+
+    dats_home = os.environ.get("DATS_HOME")
+    if not dats_home:
+        print("Error: DATS_HOME environment variable must be set.")
+        sys.exit(1)
+
+    scripts_dir = Path(dats_home) / "scripts"
+
+    if not args.ats.exists():
+        print(f"ATS JSON file does not exist: {args.ats}")
+        sys.exit(1)
+
+    commands = load_commands(args.ats)
+    stop_services(commands, scripts_dir)
+
+if __name__ == "__main__":
+    main()
diff --git a/build_with_cmake.sh b/build_with_cmake.sh
index 3df0cb92..724ff5ff 100755
--- a/build_with_cmake.sh
+++ b/build_with_cmake.sh
@@ -6,7 +6,7 @@ set -ex  # Print each command and exit on error
 OS="$(uname)"
 if [[ "$OS" == "Darwin" ]]; then
   LIB_PATH_VAR="DYLD_LIBRARY_PATH"
-  CMAKE_FLAGS="-G Xcode"
+#  CMAKE_FLAGS="-G Xcode"
 else
   LIB_PATH_VAR="LD_LIBRARY_PATH"
 fi
@@ -53,20 +53,6 @@ export LOG4CXX_HOME="$LOG4CXX_HOME"
 export $LIB_PATH_VAR="\$DATS_HOME/lib:\$DDS_HOME/lib:\$QUICKFIX_HOME/lib:\$LOG4CXX_HOME/lib:\$$LIB_PATH_VAR"
 export LOG4CXX_CONFIGURATION="\$DATS_HOME/config/log4cxx.xml"
 
-# Select one ATS config
-export BASEDIR_ATS="\$DATS_HOME/MiscATS/CryptoCLOB"
-export DATS_LOG_HOME="\$BASEDIR_ATS/logs"
-mkdir -p "\$DATS_LOG_HOME"
-
-# Uncomment one of these to switch ATS
-# export BASEDIR_ATS="\$DATS_HOME/MiscATS/USTreasuryCLOB"
-# export DATS_LOG_HOME="\$BASEDIR_ATS/logs"
-# mkdir -p "\$DATS_LOG_HOME"
-
-# export BASEDIR_ATS="\$DATS_HOME/MiscATS/MultiMatchingEngineATS"
-# export DATS_LOG_HOME="\$BASEDIR_ATS/logs"
-# mkdir -p "\$DATS_LOG_HOME"
-
 EOM
 
 chmod +x "$INSTALL_PREFIX/dats_env.sh"
diff --git a/docker/Docker.Build_DATS_Deps b/docker/Docker.Build_DATS_Deps
new file mode 100644
index 00000000..43939d94
--- /dev/null
+++ b/docker/Docker.Build_DATS_Deps
@@ -0,0 +1,15 @@
+FROM ubuntu:latest AS dats_dependency_builder
+
+RUN apt-get update
+RUN apt install -y vim cmake curl build-essential libapr1-dev libaprutil1-dev git libboost-all-dev sqlite3 libsqlite3-dev libtool libasio-dev libtinyxml2-dev zip python3-pip
+RUN pip install psutil --break-system-packages
+
+ADD build_dependences.sh /
+RUN /build_dependences.sh
+
+FROM ubuntu:latest
+RUN apt-get update && apt-get install --no-install-recommends -y \
+    libboost-all-dev vim python3-pip libapr1-dev libaprutil1-dev libtinyxml2-dev \
+ && apt-get clean && rm -rf /var/lib/apt/lists/*
+
+COPY --from=dats_dependency_builder /usr/local /usr/local
diff --git a/docker/Docker.Build_Distributed_ATS b/docker/Docker.Build_Distributed_ATS
index c0039a33..42b878bd 100644
--- a/docker/Docker.Build_Distributed_ATS
+++ b/docker/Docker.Build_Distributed_ATS
@@ -1,12 +1,9 @@
-FROM ubuntu:latest as dats_dependency_builder
+FROM ghcr.io/mkipnis/distributed_ats_deps AS dats_builder
 
 RUN apt-get update
 RUN apt install -y vim cmake curl build-essential libapr1-dev libaprutil1-dev git libboost-all-dev sqlite3 libsqlite3-dev libtool libasio-dev libtinyxml2-dev zip python3-pip
 RUN pip install psutil --break-system-packages
 
-ADD build_dependences.sh /
-RUN /build_dependences.sh
-
 ADD build_distributed_ats.sh /
 RUN /build_distributed_ats.sh
 
@@ -15,4 +12,4 @@ RUN apt-get update && apt-get install --no-install-recommends -y \
     libboost-all-dev vim python3-pip libapr1-dev libaprutil1-dev libtinyxml2-dev \
  && apt-get clean && rm -rf /var/lib/apt/lists/*
 
-COPY --from=dats_dependency_builder /usr/local /usr/local
+COPY --from=dats_builder /usr/local /usr/local
diff --git a/docker/Docker.Crypto_CLOB b/docker/Docker.Crypto_CLOB
index 1119678f..aa994198 100644
--- a/docker/Docker.Crypto_CLOB
+++ b/docker/Docker.Crypto_CLOB
@@ -4,6 +4,6 @@ EXPOSE 15001
 EXPOSE 16001
 EXPOSE 17001
 
-COPY crypto_clob_env.sh /usr/local/dats_env.sh
+COPY dats_env.sh /usr/local/dats_env.sh
 COPY FastDDS.xml /usr/local/
 RUN chmod +x /usr/local/dats_env.sh
diff --git a/docker/Docker.UST_CLOB b/docker/Docker.UST_CLOB
index bd30cae4..aa994198 100644
--- a/docker/Docker.UST_CLOB
+++ b/docker/Docker.UST_CLOB
@@ -4,6 +4,6 @@ EXPOSE 15001
 EXPOSE 16001
 EXPOSE 17001
 
-COPY ust_clob_env.sh /usr/local/dats_env.sh
+COPY dats_env.sh /usr/local/dats_env.sh
 COPY FastDDS.xml /usr/local/
 RUN chmod +x /usr/local/dats_env.sh
diff --git a/docker/crypto_clob_env.sh b/docker/dats_env.sh
similarity index 65%
rename from docker/crypto_clob_env.sh
rename to docker/dats_env.sh
index 474162b5..ab359fcf 100644
--- a/docker/crypto_clob_env.sh
+++ b/docker/dats_env.sh
@@ -4,8 +4,3 @@ export DEPS_HOME=/usr/local
 export LD_LIBRARY_PATH=$DEPS_HOME/lib:$LD_LIBRARY_PATH
 export LOG4CXX_CONFIGURATION=$DATS_HOME/config/log4cxx.xml
 export FASTDDS_DEFAULT_PROFILES_FILE=/usr/local/FastDDS.xml
-
-# ATS HOME
-export BASEDIR_ATS=$DATS_HOME/MiscATS/CryptoCLOB
-export DATS_LOG_HOME=$BASEDIR_ATS/logs
-mkdir -p $BASEDIR_ATS/logs
diff --git a/docker/docker-compose-crypto.yml b/docker/docker-compose-crypto.yml
index 4b5fafbf..8f58a97a 100644
--- a/docker/docker-compose-crypto.yml
+++ b/docker/docker-compose-crypto.yml
@@ -1,8 +1,8 @@
-version: '2'
+version: '3'
 
 services:
   fast_dds_discovery:
-    container_name: discovery_service
+    container_name: fast_dds_discovery 
     image: ghcr.io/mkipnis/distributed_ats:latest
     command: >
       bash -c "LD_LIBRARY_PATH=/usr/local/lib /usr/local/bin/fastdds discovery -q 51000"
@@ -14,9 +14,9 @@ services:
     container_name: distributed_ats
     image: ghcr.io/mkipnis/dats_crypto_clob:latest
     depends_on:
-      - discovery_service
+      - fast_dds_discovery
     command: >
-      bash -c "cd /usr/local && source ./dats_env.sh && cd $$BASEDIR_ATS/scripts && ./start_ats.sh"
+      bash -c "cd /usr/local && source ./dats_env.sh && cd MiscATS && BASEDIR_ATS=`pwd`/CryptoCLOB python3 start_ats.py --ats CryptoCLOB/crypto_ats.json"
     volumes:
       - ./logs_ats:/usr/local/MiscATS/CryptoCLOB/logs
     ports:
@@ -25,7 +25,6 @@ services:
       - "17001:17001"
     restart: unless-stopped
 
-  # WebTrader Front-End
   distributed_ats_webtrader:
     container_name: distributed_ats_webtrader
     image: ghcr.io/mkipnis/distributed_ats_webtrader:latest
diff --git a/docker/docker-compose-ust.yml b/docker/docker-compose-ust.yml
index e6ff1bdf..3e3f49b2 100644
--- a/docker/docker-compose-ust.yml
+++ b/docker/docker-compose-ust.yml
@@ -14,15 +14,14 @@ services:
     container_name: distributed_ats
     image: ghcr.io/mkipnis/dats_ust_clob:latest 
     depends_on:
-      - discovery_service
+      - fast_dds_discovery 
     command: >
-      bash -c "cd /usr/local && source ./dats_env.sh && cd $$BASEDIR_ATS/scripts && ./start_ats.sh"
+      bash -c "cd /usr/local && source ./dats_env.sh && cd MiscATS && BASEDIR_ATS=`pwd`/USTreasuryCLOB python3 start_ats.py --ats USTreasuryCLOB/ust_ats.json"
     volumes:
-      - ./logs_ats:/usr/local/MiscATS/CryptoCLOB/logs
+      - ./logs_ats:/usr/local/MiscATS/USTreasuryCLOB/logs
     ports:
       - "15001:15001"
       - "16001:16001"
-      - "17001:17001"
     restart: unless-stopped
 
   # WebTrader Front-End
diff --git a/docker/dockerize_dats.sh b/docker/dockerize_dats.sh
index 11174fe5..126bce9c 100755
--- a/docker/dockerize_dats.sh
+++ b/docker/dockerize_dats.sh
@@ -3,10 +3,12 @@
 set -x 
 
 # Core
-docker build -t ghcr.io/mkipnis/distributed_ats:latest -f Docker.Build_Distributed_ATS.debug .
+docker build -t ghcr.io/mkipnis/distributed_ats_deps:latest -f Docker.Build_DATS_Deps .
+docker build -t ghcr.io/mkipnis/distributed_ats:latest -f Docker.Build_Distributed_ATS .
 docker build --no-cache -t ghcr.io/mkipnis/dats_crypto_clob:latest -f Docker.Crypto_CLOB .
 docker build --no-cache -t ghcr.io/mkipnis/dats_ust_clob:latest -f Docker.UST_CLOB .
 
-#docker push ghcr.io/mkipnis/distributed_ats:latest
-#docker push ghcr.io/mkipnis/dats_crypto_clob:latest
-#docker push ghcr.io/mkipnis/dats_ust_clob:latest
+docker push ghcr.io/mkipnis/distributed_ats_deps:latest
+docker push ghcr.io/mkipnis/distributed_ats:latest
+docker push ghcr.io/mkipnis/dats_crypto_clob:latest
+docker push ghcr.io/mkipnis/dats_ust_clob:latest
diff --git a/docker/start_ust_clob.sh b/docker/start_ust_clob.sh
deleted file mode 100755
index 8642b2a0..00000000
--- a/docker/start_ust_clob.sh
+++ /dev/null
@@ -1,35 +0,0 @@
-#!/bin/bash
-
-trap cleanup 1 2 3 6
-
-cleanup()
-{
-	echo "Caught Signal ... cleaning up..."
-
-	$BASEDIR_ATS/scripts/stop_ats.sh
-
-	echo "Done."
-
-	exit 1;
-}
-
-sleep 1 
-$DATS_HOME/scripts/matchingengine.sh start matching_engine_MARKET_UST.ini
-
-sleep 1
-$DATS_HOME/scripts/dataservice.sh start data_service_a.ini
-$DATS_HOME/scripts/dataservice.sh start data_service_b.ini
-
-sleep 1
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_1.cfg
-$DATS_HOME/scripts/fixgateway.sh start fix_gwy_2.cfg
-
-while true; do 
-	$DATS_HOME/scripts/dataservice.sh check data_service_a.ini
-	$DATS_HOME/scripts/dataservice.sh check data_service_b.ini
-	$DATS_HOME/scripts/matchingengine.sh check matching_engine_MARKET_UST.ini
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_1.cfg
-	$DATS_HOME/scripts/fixgateway.sh check fix_gwy_2.cfg
-
-	sleep 10;
-done
diff --git a/docker/ust_clob_env.sh b/docker/ust_clob_env.sh
deleted file mode 100644
index b200dc3d..00000000
--- a/docker/ust_clob_env.sh
+++ /dev/null
@@ -1,11 +0,0 @@
-# dependencies
-export DATS_HOME=/usr/local
-export DEPS_HOME=/usr/local
-export LD_LIBRARY_PATH=$DEPS_HOME/lib:$LD_LIBRARY_PATH
-export LOG4CXX_CONFIGURATION=$DATS_HOME/config/log4cxx.xml
-export FASTDDS_DEFAULT_PROFILES_FILE=/usr/local/FastDDS.xml
-
-# ATS HOME
-export BASEDIR_ATS=$DATS_HOME/MiscATS/USTreasuryCLOB
-export DATS_LOG_HOME=$BASEDIR_ATS/logs
-mkdir -p $BASEDIR_ATS/logs