replaced ruby broker for go implementation