messages.add(message.payload)
            if (messages.size() == 20) {
                instant.messagesReceived
            }
        }

        and:
        hub.addConnection(connection1)
        hub.addConnection(connection2)

        when:
        def dispatcher = hub.getOutgoing("channel", Long)
        20.times { dispatcher.dispatch(it) }
        thread.blockUntil.messagesReceived

            hub.addHandler(channel, handler)
        }

        def connectTo(Participant other) {
            def connector = new TestConnector()
            hub.addConnection(connector.connectionA)
            other.hub.addConnection(connector.connectionB)
        }

        def stop() {
            hub.stop()
        }
    }

    private class TestConnector {

 * Use {@link #addHandler(String, Object)} to create a worker for incoming messages on a given channel.
 * Use {@link #addConnection(RemoteConnection)} to attach another router to this router.
 *
 * TODO - this type could be simplified, as there is no longer any need to send/receive messages to/from multiple connections
 */

                new MethodInvocationSerializer(
                    methodParamClassLoader,
                    argsSerializer)));

        connection = completion.create(serializer);
        hub.addConnection(connection);
        hub.noFurtherConnections();
        completion = null;
    }

    @Override
    public void requestStop() {
        hub.requestStop();
    }

    @Override