added worker pool, changed pub/sub into 2 connections