class MessageBrokerClient extends Client {

    public Cdr waitForMsgOnTopic(Optional<String> topic, int milliseconds) throws EtiqetException {
        return getTransport().subscribeAndConsumeFromTopic(topic, Duration.ofMillis(milliseconds));
    }

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

}