publisher.publish(policyMsg);
log.info("send policyMsg: " + JacksonUtil.beanToJson(policyMsg));
} catch (CorrelationException e) {
log.error("Failed to publish policyMsg to dmaap", e.getMessage());
} catch (JsonProcessingException e) {
log.info("Failed to convert policyMsg to json");
publisher.publish(policyMsg);
log.info("send policyMsg: " + JacksonUtil.beanToJson(policyMsg));
} catch (CorrelationException e) {
log.error("Failed to publish policyMsg to dmaap", e.getMessage());
} catch (JsonProcessingException e) {
log.info("Failed to convert policyMsg to json");