tests run OK, need to implement pub/sub queue