public interface Subscribable<T> extends Callback<T>
DisposingExecutor
getQueue()
onMessage
DisposingExecutor getQueue()
Copyright © 2017. All Rights Reserved.