removed prefix from extension name

Signed-off-by: minghuaw <[email protected]>

Author: minghuaw

Cargo.toml

@@ -25,7 +25,7 @@ warp = ["warp-lib", "bytes", "http", "hyper"]
 axum = ["bytes", "http", "hyper", "axum-lib", "http-body", "async-trait"]
 poem = ["bytes", "http", "poem-lib", "hyper", "async-trait"]
 nats = ["nats-lib"]
-fe2o3-amqp = ["fe2o3-amqp-lib", "fe2o3-amqp-types"]
+fe2o3-amqp = ["fe2o3-amqp-types"]
 
 [dependencies]
 serde = { version = "^1.0", features = ["derive"] }
@@ -53,7 +53,6 @@ axum-lib = { version = "^0.5", optional = true , package="axum"}
 http-body = { version = "^0.4", optional = true }
 poem-lib = { version = "=1.2.34", optional = true, package = "poem" }
 nats-lib = { version = "0.21.0", optional = true, package = "nats" }
-fe2o3-amqp-lib = { version = "0.4.0", optional = true, package = "fe2o3-amqp" }
 fe2o3-amqp-types = { version = "0.3.4", optional = true }
 
 [target."cfg(not(target_arch = \"wasm32\"))".dependencies]

src/binding/fe2o3_amqp/mod.rs

@@ -4,8 +4,8 @@ use std::collections::HashMap;
 use std::convert::TryFrom;
 
 use chrono::{TimeZone, Utc};
-use fe2o3_amqp_lib::types::messaging::{ApplicationProperties, Body, Message, Properties};
-use fe2o3_amqp_lib::types::primitives::{Binary, SimpleValue, Symbol, Timestamp, Value};
+use fe2o3_amqp_types::messaging::{ApplicationProperties, Body, Message, Properties};
+use fe2o3_amqp_types::primitives::{Binary, SimpleValue, Symbol, Timestamp, Value};
 
 use crate::event::{AttributeValue, ExtensionValue};
 use crate::message::{BinaryDeserializer, Error, MessageAttributeValue, StructuredDeserializer};

src/binding/fe2o3_amqp/serializer.rs

@@ -60,7 +60,7 @@ impl BinarySerializer<EventMessage> for EventMessage {
         name: &str,
         value: MessageAttributeValue,
     ) -> crate::message::Result<Self> {
-        let key = header_prefix(ATTRIBUTE_PREFIX, name);
+        let key = name.to_string();
         let value = SimpleValue::from(value);
         self.application_properties
             .get_or_insert(ApplicationProperties::default())