class ExchangeBrokerClient extends Client {

    public void subscribeToQueue(final String queueName) throws EtiqetException {
        getTransport().subscribeToQueue(
            queueName,
            message -> addMessageToGroup(messagesByQueue, queueName, message)
        );
    }

    public  ExchangeBrokerClient(String clientConfig);
    public  ExchangeBrokerClient(String primaryClientConfig, String secondaryClientConfig);
    public  ExchangeBrokerClient(String primaryClientConfig, String secondaryClientConfig, ProtocolConfig protocol);

}