7
7
//! use serde_json::json;
8
8
//! use fe2o3_amqp::{Connection, Sender, Session};
9
9
//! use cloudevents::{
10
- //! EventBuilder, EventBuilderV10,
10
+ //! EventBuilder, EventBuilderV10,
11
11
//! binding::fe2o3_amqp::{EventMessage, AmqpMessage}
12
12
//! };
13
13
//!
@@ -121,7 +121,7 @@ pub type AmqpBody = Body<Value>;
121
121
/// use serde_json::json;
122
122
/// use fe2o3_amqp_types::messaging::Message;
123
123
/// use cloudevents::{EventBuilder, EventBuilderV10, binding::fe2o3_amqp::EventMessage};
124
- ///
124
+ ///
125
125
/// let event = EventBuilderV10::new()
126
126
/// .id("1")
127
127
/// .ty("example.test")
@@ -140,7 +140,7 @@ pub type AmqpBody = Body<Value>;
140
140
/// use serde_json::json;
141
141
/// use fe2o3_amqp_types::messaging::Message;
142
142
/// use cloudevents::{EventBuilder, EventBuilderV10, binding::fe2o3_amqp::EventMessage};
143
- ///
143
+ ///
144
144
/// let event = EventBuilderV10::new()
145
145
/// .id("1")
146
146
/// .ty("example.test")
@@ -161,7 +161,7 @@ pub type AmqpBody = Body<Value>;
161
161
/// message::MessageDeserializer,
162
162
/// binding::fe2o3_amqp::{AmqpMessage, EventMessage}
163
163
/// };
164
- ///
164
+ ///
165
165
/// # async fn receive_event(receiver: &mut Receiver) {
166
166
/// let delivery = receiver.recv().await.unwrap();
167
167
/// receiver.accept(&delivery).await.unwrap();
0 commit comments