}
            }
        } finally {
            lock.unlock();
        }
    }

    private class ConnectionWorker implements Runnable {
        private final SynchronizedDispatchConnection<Message> connection;

        public ConnectionWorker(SynchronizedDispatchConnection<Message> connection) {
            this.connection = connection;
        }

        @Override