Revert "BAEL-3275: Using blocking queue for pub-sub"
Run Integration Tests with mvn integration-test
mvn integration-test