+
+ MRConsumer getMessageRouterConsumer(Properties dmaapConsumerProperties) throws IOException {
+ return MRClientFactory.createConsumer(dmaapConsumerProperties);
+ }
+
+ DmaapMessageHandler createDmaapMessageHandler(AsyncRestClient agentClient, MRBatchingPublisher producer) {
+ return new DmaapMessageHandler(producer, agentClient);
+ }
+
+ AsyncRestClient createRestClient(String agentBaseUrl) {
+ return new AsyncRestClient(agentBaseUrl);
+ }
+
+ MRBatchingPublisher getMessageRouterPublisher(Properties dmaapPublisherProperties) throws IOException {
+ return MRClientFactory.createBatchingPublisher(dmaapPublisherProperties);
+ }