- if (!"200".equals(response.getResponseCode())) {
- logger.error("DMaaP consumer received: {} : {}", response.getResponseCode(),
- response.getResponseMessage());
- }
- }
- return response.getActualMessages();
- }
-
- @PostConstruct
- @Override
- public void init() {
- Properties dmaapConsumerProperties = applicationConfig.getDmaapConsumerConfig();
- Properties dmaapPublisherProperties = applicationConfig.getDmaapPublisherConfig();
- // No need to start if there is no configuration.
- if (dmaapConsumerProperties == null || dmaapPublisherProperties == null || dmaapConsumerProperties.size() == 0
- || dmaapPublisherProperties.size() == 0) {
- logger.error("DMaaP properties Failed to Load");
- return;
- }
- try {
- logger.debug("Creating DMAAP Client");
- consumer = MRClientFactory.createConsumer(dmaapConsumerProperties);
- this.alive = true;
- } catch (IOException e) {
- logger.error("Exception occurred while creating Dmaap Consumer", e);