The onAutoReconnected event handler was never set tot the connection handler.

When connecting fails on first call of connect() on the MQTT client. Then you invoke the doAutoReconnect() method (and also set the autoReconnect property to true). When it connects, the server connections don't have a readWrapper and messagStream, which result in exceptions.

Initialize the readWrapper and messageStream in the base connection class.

Removed the creation of those objects in the connection classes in the socket callbacks.

; too much