public interface SubscriptionListener<T>
void
onError(java.lang.Exception e)
onMessage(T message)
void onMessage(T message)
void onError(java.lang.Exception e)