private RequestContext buildRequestContext()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListener.java [224:237]


  private RequestContext buildRequestContext(MessageHeaders headers) {
    RequestContext context = new RequestContext();
    context.setApplication(getFromHeaders(headers, X_SOURCE_APPLICATION));
    context.setSystem(getFromHeaders(headers, X_SOURCE_SYSTEM));
    context.setBusinessProcess(getFromHeaders(headers, X_SOURCE_BUSINESS_PROCESS));
    context.setBusinessProcessInstanceId(
        getFromHeaders(headers, X_SOURCE_BUSINESS_PROCESS_INSTANCE_ID));
    context.setBusinessActivity(getFromHeaders(headers, X_SOURCE_BUSINESS_ACTIVITY));
    context.setBusinessActivityInstanceId(
        getFromHeaders(headers, X_SOURCE_BUSINESS_ACTIVITY_INSTANCE_ID));
    context.setBusinessProcessDefinitionId(
        getFromHeaders(headers, X_SOURCE_BUSINESS_PROCESS_DEFINITION_ID));
    return context;
  }