acceptor.bind(new InetSocketAddress(1234));  

public interface IoAcceptor extends IoService {
void bind() throws IOException;
void bind(SocketAddress localAddress) throws IOException;
void bind(SocketAddress firstLocalAddress, SocketAddress... addresses) throws IOException;
void bind(Iterable<? extends SocketAddress> localAddresses) throws IOException;
void unbind();
void unbind(SocketAddress localAddress);
void unbind(SocketAddress firstLocalAddress, SocketAddress... otherLocalAddresses);
void unbind(Iterable<? extends SocketAddress> localAddresses);
} 

protected final Set<SocketAddress> bindInternal(List<? extends SocketAddress> localAddresses) throws Exception {// Create a bind request as a Future operation. When the selector// have handled the registration, it will signal this future.AcceptorOperationFuture request = new AcceptorOperationFuture(localAddresses);// adds the Registration request to the queue for the Workers// to handle
        registerQueue.add(request);// creates the Acceptor instance and has the local// executor kick it off.
        startupAcceptor();// As we just started the acceptor, we have to unblock the select()// in order to process the bind request we just have added to the// registerQueue.try {lock.acquire();// Wait a bit to give a chance to the Acceptor thread to do the select()Thread.sleep(10);wakeup();} finally {lock.release();}// Now, we wait until this request is completed.
        request.awaitUninterruptibly();if (request.getException() != null) {throw request.getException();}// Update the local addresses.// setLocalAddresses() shouldn't be called from the worker thread// because of deadlock.Set<SocketAddress> newLocalAddresses = new HashSet<SocketAddress>();for (H handle : boundHandles.values()) {newLocalAddresses.add(localAddress(handle));}return newLocalAddresses;

        public void run() {assert (acceptorRef.get() == this);int nHandles = 0;// Release the lock
            lock.release();while (selectable) {try {// Detect if we have some keys ready to be processed// The select() will be woke up if some new connection// have occurred, or if the selector has been explicitly// woke upint selected = select();// this actually sets the selector to OP_ACCEPT,// and binds to the port on which this class will// listen onnHandles += registerHandles();// Now, if the number of registred handles is 0, we can// quit the loop: we don't have any socket listening// for incoming connection.if (nHandles == 0) {acceptorRef.set(null);if (registerQueue.isEmpty() && cancelQueue.isEmpty()) {assert (acceptorRef.get() != this);break;}if (!acceptorRef.compareAndSet(null, this)) {assert (acceptorRef.get() != this);break;}assert (acceptorRef.get() == this);}if (selected > 0) {// We have some connection request, let's process// them here.
                        processHandles(selectedHandles());}// check to see if any cancellation request has been made.nHandles -= unregisterHandles();} catch (ClosedSelectorException cse) {// If the selector has been closed, we can exit the loopbreak;} catch (Throwable e) {ExceptionMonitor.getInstance().exceptionCaught(e);try {Thread.sleep(1000);} catch (InterruptedException e1) {ExceptionMonitor.getInstance().exceptionCaught(e1);}}}// Cleanup all the processors, and shutdown the acceptor.if (selectable && isDisposing()) {selectable = false;try {if (createdProcessor) {processor.dispose();}} finally {try {synchronized (disposalLock) {if (isDisposing()) {destroy();}}} catch (Exception e) {ExceptionMonitor.getInstance().exceptionCaught(e);} finally {disposalFuture.setDone();}}}}

    private int registerHandles() {for (;;) {// The register queue contains the list of services to manage// in this acceptor.AcceptorOperationFuture future = registerQueue.poll();if (future == null) {return 0;}// We create a temporary map to store the bound handles,// as we may have to remove them all if there is an exception// during the sockets opening.Map<SocketAddress, H> newHandles = new ConcurrentHashMap<SocketAddress, H>();List<SocketAddress> localAddresses = future.getLocalAddresses();try {// Process all the addressesfor (SocketAddress a : localAddresses) {H handle = open(a);newHandles.put(localAddress(handle), handle);}// Everything went ok, we can now update the map storing// all the bound sockets.
                boundHandles.putAll(newHandles);// and notify.
                future.setDone();return newHandles.size();} catch (Exception e) {// We store the exception in the future
                future.setException(e);} finally {// Roll back if failed to bind all addresses.if (future.getException() != null) {for (H handle : newHandles.values()) {try {close(handle);} catch (Exception e) {ExceptionMonitor.getInstance().exceptionCaught(e);}}// TODO : add some comment : what is the wakeup() waking up ?
                    wakeup();}}}}

    protected ServerSocketChannel open(SocketAddress localAddress) throws Exception {// Creates the listening ServerSocketServerSocketChannel channel = ServerSocketChannel.open();boolean success = false;try {// This is a non blocking socket channelchannel.configureBlocking(false);// Configure the server socket,ServerSocket socket = channel.socket();// Set the reuseAddress flag accordingly with the setting
            socket.setReuseAddress(isReuseAddress());// and bind.
            socket.bind(localAddress, getBacklog());// Register the channel within the selector for ACCEPT event
            channel.register(selector, SelectionKey.OP_ACCEPT);success = true;} finally {if (!success) {close(channel);}}return channel;}

        private void processHandles(Iterator<H> handles) throws Exception {while (handles.hasNext()) {H handle = handles.next();handles.remove();// Associates a new created connection to a processor,// and get back a sessionS session = accept(processor, handle);if (session == null) {continue;}initSession(session, null, null);// add the session to the SocketIoProcessor
                session.getProcessor().add(session);}}

    protected void init(NioSession session) throws Exception {SelectableChannel ch = (SelectableChannel) session.getChannel();ch.configureBlocking(false);session.setSelectionKey(ch.register(selector, SelectionKey.OP_READ, session));}