private MessageHeaders buildHeaders()

in src/it/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListenerIT.java [214:225]

• 12 lines of code
• 1 McCabe index (conditional complexity)

  private MessageHeaders buildHeaders() {
    Map<String, Object> map = new HashMap<>();
    map.put(TOPIC, kafkaProperties.getTopics().get("data-load-csv-inbound"));
    map.put(RESULT_VARIABLE, RESULT_VARIABLE);
    map.put(X_ACCESS_TOKEN, mockJwt());
    map.put(DIGITAL_SEAL, DIGITAL_SEAL);
    map.put(ENTITY_NAME, ENTITY_NAME);
    map.put(X_DIGITAL_SIGNATURE, X_DIGITAL_SIGNATURE);
    map.put(X_DIGITAL_SIGNATURE_DERIVED, X_DIGITAL_SIGNATURE_DERIVED);
    map.put(X_SOURCE_BUSINESS_PROCESS_INSTANCE_ID, X_SOURCE_BUSINESS_PROCESS_INSTANCE_ID);
    return new MessageHeaders(map);
  }