in sdk/core/azure_core_amqp/src/fe2o3/messaging/message_fields.rs [379:424]
fn from(properties: AmqpMessageProperties) -> Self {
let mut properties_builder = fe2o3_amqp_types::messaging::Properties::builder();
if let Some(message_id) = &properties.message_id {
properties_builder = properties_builder.message_id(message_id.clone());
}
if let Some(user_id) = &properties.user_id {
properties_builder = properties_builder.user_id(user_id.clone());
}
if let Some(to) = properties.to {
properties_builder = properties_builder.to(to.clone());
}
if let Some(subject) = properties.subject {
properties_builder = properties_builder.subject(subject.clone());
}
if let Some(reply_to) = properties.reply_to {
properties_builder = properties_builder.reply_to(reply_to.clone());
}
if let Some(correlation_id) = properties.correlation_id {
properties_builder = properties_builder.correlation_id(correlation_id.clone());
}
if let Some(content_type) = properties.content_type {
properties_builder = properties_builder.content_type(content_type.clone());
}
if let Some(content_encoding) = properties.content_encoding {
properties_builder = properties_builder.content_encoding(content_encoding.clone());
}
if let Some(absolute_expiry_time) = properties.absolute_expiry_time {
properties_builder =
properties_builder.absolute_expiry_time(Some(absolute_expiry_time.clone().into()));
}
if let Some(creation_time) = properties.creation_time {
properties_builder =
properties_builder.creation_time(Some(creation_time.clone().into()));
}
if let Some(group_id) = properties.group_id {
properties_builder = properties_builder.group_id(group_id.clone());
}
if let Some(group_sequence) = properties.group_sequence {
properties_builder = properties_builder.group_sequence(group_sequence);
}
if let Some(reply_to_group_id) = properties.reply_to_group_id {
properties_builder = properties_builder.reply_to_group_id(reply_to_group_id.clone());
}
properties_builder.build()
}