pcvolkmer/bwhc-kafka-proxy
1
0
Fork 0
mirror of https://github.com/CCC-MF/bwhc-kafka-rest-proxy.git synced 2025-04-19 19:16:51 +00:00
Code Issues Activity

feat: send content type in record header

Browse Source
This commit is contained in:
Paul-Christian Volkmer 2025-04-07 20:20:13 +02:00
parent 5aa1c57d0d
commit dc24d0882e
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/sender.rs
View File

@ -36,10 +36,15 @@ impl MtbFileSender {
patient_id: mtb_file.patient.id.to_string(),
};
let record_headers = OwnedHeaders::default().insert(Header {
key: "requestId",
value: Some(&request_id.to_string()),
});
let record_headers = OwnedHeaders::default()
.insert(Header {
key: "contentType",
value: Some("application/json"),
})
.insert(Header {
key: "requestId",
value: Some(&request_id.to_string()),
});
let record_key = serde_json::to_string(&record_key).map_err(|_| ())?;