Added code to insert the job into the 'read_pending' queue.

import json

from amqp_server import AMQPServer

from config import Config

from db_connector import DbConnector

from job import Job

from config import Config

from job_queue import JobQueue

class StartJobAMQPServer(AMQPServer):

                                  self.params["host"], 

                                  self.params.getint("port"), 

                                  self.params["db"])

        self.pendingQueueRead = JobQueue("read_pending")

        super(StartJobAMQPServer, self).__init__(host, port, queue)      

    def execute_callback(self, requestBody):

        dbResponse = self.dbConn.getJob(self.job.jobId)

        self.dbConn.disconnect()

        print(f"Db response: {dbResponse}")

        self.pendingQueueRead.insertJob(self.job)

        t = threading.Thread(target = self.fake_job) # only for testing purposes

        t.start()                                    # only for testing purposes

        return dbResponse