configZKConsumer(),
};
}
@Configuration
public static Option[] configure() throws Exception {
<BUG>return new Option[] {
rsaCoreZookeeper(),
</BUG>
rsaTcp(),
RsaTestBase.echoTcpConsumer(),

configZKConsumer(),
};
}
@Configuration
public static Option[] configure() throws Exception {
return new Option[] {
rsaCore(),
rsaDiscoveryZookeeper(),
rsaTcp(),
RsaTestBase.echoTcpConsumer(),
