RESOLVED - issue PC-3: Modularize Message Queue 
https://anyflow.atlassian.net/browse/PC-3