Added initial logic for message queue framework