class DmaapPropertiesClient {

    public void dmaapPublishRequest(String requestId, String clientSource, String correlator, String serviceInstanceId,
            String startTime, String finishTime, String requestScope, String requestType, String timestamp,
            String requestState, String statusMessage, String percentProgress, Boolean wasRolledBack)
            throws MapperException, JsonProcessingException {

        AVPNDmaapBean bean = this.buildRequestJson(requestId, clientSource, correlator, serviceInstanceId, startTime,
                finishTime, requestScope, requestType, timestamp, requestState, statusMessage, percentProgress,
                wasRolledBack);

        String request = jsonToString(bean);
        dmaapPublisher.get().send(request);
    }

}