In progress commit, java implementation of single broker setup.