Instead of initializing a local variable first and then return it, you could directly return a new Builder instance. -> return new Builder().uri(URL).build();
Revert "BAEL-3275: Using blocking queue for pub-sub"