File tree Expand file tree Collapse file tree 2 files changed +1
-4
lines changed Expand file tree Collapse file tree 2 files changed +1
-4
lines changed Original file line number Diff line number Diff line change @@ -59,9 +59,6 @@ impl BinaryDeserializer for EventMessage {
59
59
let value = MessageAttributeValue :: try_from ( value) ?;
60
60
serializer = serializer. set_extension ( key, value) ?;
61
61
}
62
- } else {
63
- let value = MessageAttributeValue :: try_from ( value) ?;
64
- serializer = serializer. set_extension ( & key, value) ?;
65
62
}
66
63
}
67
64
}
Original file line number Diff line number Diff line change @@ -60,7 +60,7 @@ impl BinarySerializer<EventMessage> for EventMessage {
60
60
name : & str ,
61
61
value : MessageAttributeValue ,
62
62
) -> crate :: message:: Result < Self > {
63
- let key = name . to_string ( ) ;
63
+ let key = header_prefix ( ATTRIBUTE_PREFIX , name ) ;
64
64
let value = SimpleValue :: from ( value) ;
65
65
self . application_properties
66
66
. get_or_insert ( ApplicationProperties :: default ( ) )
You can’t perform that action at this time.
0 commit comments