public void addLoginListener ( LoginListener listener ) { logger . debug ( "addLoginListener" ) ; Subscription subscription = loginEventPublisher . subscribeOn ( config . subscribeOn ( ) ) . observeOn ( config . observeOn ( ) ) . subscribe ( listener ) ; listener . setSubscription ( subscription ) ; }
Add loginListener to listen to login events