Thread.sleep(1000);
authData = new JsonObject();
authData.addProperty( "username", "Yasser" );
DeepstreamClient ds2 = new DeepstreamClient( "localhost:6021" );
ds2
<BUG>.addConnectionChangeListener( this )
.setRuntimeErrorHandler(new DeepstreamRuntimeErrorHandler() {</BUG>
@Override
public void onException(Topic topic, Event event, String msg) {
System.out.println( "Error occured " + topic + " " + event + " " + msg );

Thread.sleep(1000);
authData = new JsonObject();
authData.addProperty( "username", "Yasser" );
DeepstreamClient ds2 = new DeepstreamClient( "localhost:6021" );
ds2
.addConnectionChangeListener( this )
.login( authData, this )
.setRuntimeErrorHandler(new DeepstreamRuntimeErrorHandler() {
@Override
public void onException(Topic topic, Event event, String msg) {
System.out.println( "Error occured " + topic + " " + event + " " + msg );
