in sdk/eventhubs/azure_messaging_eventhubs/src/models/event_data.rs [119:148]
fn from(event_data: EventData) -> Self {
let mut message_builder = AmqpMessage::builder();
if event_data.content_type.is_some()
|| event_data.correlation_id.is_some()
|| event_data.message_id.is_some()
{
let mut message_properties = AmqpMessageProperties::default();
if let Some(content_type) = event_data.content_type {
message_properties.content_type = Some(content_type.into());
}
if let Some(correlation_id) = event_data.correlation_id {
message_properties.correlation_id = Some(correlation_id.into());
}
if let Some(message_id) = event_data.message_id {
message_properties.message_id = Some(message_id.into());
}
message_builder = message_builder.with_properties(message_properties);
}
if let Some(properties) = event_data.properties {
for (key, value) in properties {
message_builder = message_builder.add_application_property(key, value);
}
}
if let Some(event_body) = event_data.body {
message_builder =
message_builder.with_body(AmqpMessageBody::Binary(vec![event_body.to_vec()]));
}
message_builder.build()
}