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