in sdk/core/azure_core_amqp/src/fe2o3/messaging/message_fields.rs [53:122]
fn test_message_id_conversion() {
use azure_core::Uuid;
{
let message_id = fe2o3_amqp_types::messaging::MessageId::String("test".into());
let amqp_message_id: AmqpMessageId = message_id.clone().into();
assert_eq!(amqp_message_id, AmqpMessageId::String("test".into()));
let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
assert_eq!(fe2o3_message_id, message_id);
}
{
let uuid = Uuid::new_v4();
let message_id = fe2o3_amqp_types::messaging::MessageId::Uuid(uuid.into());
let amqp_message_id: AmqpMessageId = message_id.clone().into();
assert_eq!(amqp_message_id, AmqpMessageId::from(uuid));
let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
assert_eq!(fe2o3_message_id, message_id);
}
{
let message_id = fe2o3_amqp_types::messaging::MessageId::Binary(vec![1, 2, 3].into());
let amqp_message_id: AmqpMessageId = message_id.clone().into();
assert_eq!(amqp_message_id, AmqpMessageId::Binary(vec![1, 2, 3]));
let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
assert_eq!(fe2o3_message_id, message_id);
}
{
let message_id = fe2o3_amqp_types::messaging::MessageId::Ulong(1);
let amqp_message_id: AmqpMessageId = message_id.clone().into();
assert_eq!(amqp_message_id, AmqpMessageId::Ulong(1));
let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
assert_eq!(fe2o3_message_id, message_id);
}
{
let amqp_message_id = AmqpMessageId::String("test".into());
let message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.clone().into();
assert_eq!(
message_id,
fe2o3_amqp_types::messaging::MessageId::String("test".into())
);
let amqp_round_trip: AmqpMessageId = message_id.into();
assert_eq!(amqp_round_trip, amqp_message_id);
}
{
let uuid = Uuid::new_v4();
let amqp_message_id = AmqpMessageId::from(uuid);
let message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.clone().into();
assert_eq!(
message_id,
fe2o3_amqp_types::messaging::MessageId::Uuid(fe2o3_amqp_types::primitives::Uuid::from(
uuid
))
);
let amqp_round_trip: AmqpMessageId = message_id.into();
assert_eq!(amqp_round_trip, amqp_message_id);
}
{
let amqp_message_id = AmqpMessageId::Binary(vec![1, 2, 3]);
let message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.clone().into();
assert_eq!(
message_id,
fe2o3_amqp_types::messaging::MessageId::Binary(vec![1, 2, 3].into())
);
let amqp_round_trip: AmqpMessageId = message_id.into();
assert_eq!(amqp_round_trip, amqp_message_id);
}
}