code: @Override
  	public void on(String name, Tree payload, Groups groups, boolean broadcast) throws Exception {
  
  		// A.) Async invocation
  		if (asyncLocalInvocation) {
  			executor.execute(() -> {
  				try {
  					listener.on(payload);
  				} catch (Exception cause) {
  					logger.warn("Unable to invoke local listener!", cause);
  				}
  			});
  			return;
  		}
  
  		// B.) Faster in-process (direct) invocation
  		listener.on(payload);
  	}
docs: --- INVOKE LOCAL LISTENER ---