code: protected void connect() {
  		DefaultClientResources.Builder builder = DefaultClientResources.builder();
  		acceptor = Executors.newSingleThreadExecutor();
  		group = new NioEventLoopGroup(1, acceptor);
  		builder.eventLoopGroupProvider(new EventLoopGroupProvider() {
  
  			@Override
  			public final int threadPoolSize() {
  				return 1;
  			}
  
  			@Override
  			public final Future<Boolean> shutdown(long quietPeriod, long timeout, TimeUnit timeUnit) {
  				return null;
  			}
  
  			@Override
  			public final Future<Boolean> release(EventExecutorGroup eventLoopGroup, long quietPeriod, long timeout,
  					TimeUnit unit) {
  				return null;
  			}
  
  			@SuppressWarnings("unchecked")
  			@Override
  			public final <T extends EventLoopGroup> T allocate(Class<T> type) {
  				return (T) group;
  			}
  
  		});
  		builder.eventExecutorGroup(new DefaultEventExecutor(executor));
  		if (eventBus == null) {
  			builder.eventBus(new EventBus() {
  
  				@Override
  				public final void publish(Event event) {
  
  					// Do nothing
  				}
  
  				@Override
  				public final Observable<Event> get() {
  					return null;
  				}
  
  			});
  		} else {
  			builder.eventBus(eventBus);
  		}
  		resources = builder.build();
  	}
docs: --- CONNECT ---