code: protected void disconnect() {
  		if (poller != null) {
  			poller.stop();
  		}
  		if (executor != null) {
  			try {
  				executor.shutdown();
  			} catch (Exception ignored) {
  			}
  			executor = null;
  		}
  		if (poller != null) {
  			poller = null;
  		}
  		if (producer != null) {
  			try {
  				producer.close(10, TimeUnit.SECONDS);
  			} catch (Exception ignored) {
  			}
  			producer = null;
  		}
  	}
docs: --- DISCONNECT ---