Implement pub sub connection