Ditched ActiveMQ and switched to RxJava Observables.