code: @Override
    public void connect(final Transport.ConnectionInfo connectionInfo,
                        final ElementListener elementListener, final Runnable onConnected) {
      LOGGER.fine("Connecting...");
      connected = true;
      elementReader = new ElementReader(elementListener);
      if (onConnected != null) {
        onConnected.run();
      }
    }
docs: {@inheritDoc}