renamed to EventMessage

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

Author: minghuaw

src/binding/fe2o3_amqp/deserializer.rs

@@ -13,10 +13,10 @@ use crate::{
 
 use super::{
     constants::{prefixed, DATACONTENTTYPE},
-    AmqpBinding, ATTRIBUTE_PREFIX,
+    EventMessage, ATTRIBUTE_PREFIX,
 };
 
-impl BinaryDeserializer for AmqpBinding {
+impl BinaryDeserializer for EventMessage {
     fn deserialize_binary<R: Sized, V: BinarySerializer<R>>(
         mut self,
         mut serializer: V,
@@ -74,7 +74,7 @@ impl BinaryDeserializer for AmqpBinding {
     }
 }
 
-impl StructuredDeserializer for AmqpBinding {
+impl StructuredDeserializer for EventMessage {
     fn deserialize_structured<R: Sized, V: StructuredSerializer<R>>(
         self,
         serializer: V,
@@ -89,7 +89,7 @@ impl StructuredDeserializer for AmqpBinding {
     }
 }
 
-impl MessageDeserializer for AmqpBinding {
+impl MessageDeserializer for EventMessage {
     fn encoding(&self) -> Encoding {
         match self
             .content_type

src/binding/fe2o3_amqp/mod.rs

@@ -37,13 +37,13 @@ pub type Extensions = HashMap<String, ExtensionValue>;
 /// message property field. If the value is prefixed with the CloudEvents media type
 /// application/cloudevents, indicating the use of a known event format, the receiver uses
 /// structured mode, otherwise it defaults to binary mode.
-pub struct AmqpBinding {
+pub struct EventMessage {
     content_type: Option<Symbol>,
     application_properties: Option<ApplicationProperties>,
     body: AmqpBody,
 }
 
-impl AmqpBinding {
+impl EventMessage {
     fn new() -> Self {
         Self {
             content_type: None,
@@ -52,17 +52,19 @@ impl AmqpBinding {
         }
     }
 
+    /// Create an [`EventMessage`] from an event using a binary serializer
     pub fn from_binary_event(event: Event) -> Result<Self, Error> {
         BinaryDeserializer::deserialize_binary(event, Self::new())
     }
 
+    /// Create an [`EventMessage`] from an event using a structured serializer
     pub fn from_structured_event(event: Event) -> Result<Self, Error> {
         StructuredDeserializer::deserialize_structured(event, Self::new())
     }
 }
 
-impl From<AmqpBinding> for AmqpMessage {
-    fn from(event: AmqpBinding) -> Self {
+impl From<EventMessage> for AmqpMessage {
+    fn from(event: EventMessage) -> Self {
         let mut properties = Properties::default();
         properties.content_type = event.content_type;
         Message {
@@ -77,7 +79,7 @@ impl From<AmqpBinding> for AmqpMessage {
     }
 }
 
-impl From<AmqpMessage> for AmqpBinding {
+impl From<AmqpMessage> for EventMessage {
     fn from(message: AmqpMessage) -> Self {
         let content_type = message.properties.map(|p| p.content_type).flatten();
         Self {

src/binding/fe2o3_amqp/serializer.rs

@@ -9,9 +9,9 @@ use crate::{
 };
 
 use super::constants::DATACONTENTTYPE;
-use super::{AmqpBody, AmqpBinding, ATTRIBUTE_PREFIX};
+use super::{AmqpBody, EventMessage, ATTRIBUTE_PREFIX};
 
-impl BinarySerializer<AmqpBinding> for AmqpBinding {
+impl BinarySerializer<EventMessage> for EventMessage {
     fn set_spec_version(mut self, spec_version: SpecVersion) -> crate::message::Result<Self> {
         let key = String::from("cloudEvents:specversion");
         let value = String::from(spec_version.as_str());
@@ -79,7 +79,7 @@ impl BinarySerializer<AmqpBinding> for AmqpBinding {
     }
 }
 
-impl StructuredSerializer<AmqpBinding> for AmqpBinding {
+impl StructuredSerializer<EventMessage> for EventMessage {
     fn set_structured_event(mut self, bytes: Vec<u8>) -> crate::message::Result<Self> {
         self.content_type = Some(Symbol::from("application/cloudevents+json; charset=utf-8"));
         self.body = AmqpBody::Data(AmqpData(Binary::from(bytes)));