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 {
5959 let value = MessageAttributeValue :: try_from ( value) ?;
6060 serializer = serializer. set_extension ( key, value) ?;
6161 }
62- } else {
63- let value = MessageAttributeValue :: try_from ( value) ?;
64- serializer = serializer. set_extension ( & key, value) ?;
6562 }
6663 }
6764 }
Original file line number Diff line number Diff line change @@ -60,7 +60,7 @@ impl BinarySerializer<EventMessage> for EventMessage {
6060 name : & str ,
6161 value : MessageAttributeValue ,
6262 ) -> crate :: message:: Result < Self > {
63- let key = name . to_string ( ) ;
63+ let key = header_prefix ( ATTRIBUTE_PREFIX , name ) ;
6464 let value = SimpleValue :: from ( value) ;
6565 self . application_properties
6666 . get_or_insert ( ApplicationProperties :: default ( ) )
You can’t perform that action at this time.
0 commit comments