|
1 | 1 | //! This module integrated the [cloudevents-sdk](https://docs.rs/cloudevents-sdk) with |
2 | | -//! [fe2o3-amqp](https://docs.rs/fe2o3-amqp/) to easily send and receiver CloudEvents |
| 2 | +//! [fe2o3-amqp](https://docs.rs/fe2o3-amqp/) to easily send and receive CloudEvents |
3 | 3 | //! |
4 | 4 | //! To send CloudEvents |
5 | 5 | //! |
|
12 | 12 | //! |
13 | 13 | //! #[tokio::main] |
14 | 14 | //! async fn main() { |
15 | | -//! let mut connection = |
16 | | -//! Connection::open("cloudevents-sdk-rust", "amqp://guest:guest@localhost:5672") |
17 | | -//! .await |
18 | | -//! .unwrap(); |
19 | | -//! let mut session = Session::begin(&mut connection).await.unwrap(); |
20 | | -//! let mut sender = Sender::attach(&mut session, "sender", "q1").await.unwrap(); |
21 | | -//! |
22 | | -//! let event = EventBuilderV10::new() |
23 | | -//! .id(i.to_string()) |
24 | | -//! .ty("example.test") |
25 | | -//! .source("localhost") |
26 | | -//! .extension("ext-name", "AMQP") |
27 | | -//! .data("application/json", value) |
28 | | -//! .build() |
29 | | -//! .unwrap(); |
30 | | -//! |
31 | | -//! let event_message = EventMessage::from_binary_event(event).unwrap(); |
32 | | -//! let message = AmqpMessage::from(event_message); |
33 | | -//! sender.send(message).await.unwrap() |
34 | | -//! .accepted_or("not accepted").unwrap(); |
35 | | -//! |
36 | | -//! sender.close().await.unwrap(); |
37 | | -//! session.end().await.unwrap(); |
38 | | -//! connection.close().await.unwrap(); |
| 15 | +//! let mut connection = |
| 16 | +//! Connection::open("cloudevents-sdk-rust", "amqp://guest:guest@localhost:5672") |
| 17 | +//! .await |
| 18 | +//! .unwrap(); |
| 19 | +//! let mut session = Session::begin(&mut connection).await.unwrap(); |
| 20 | +//! let mut sender = Sender::attach(&mut session, "sender", "q1").await.unwrap(); |
| 21 | +//! |
| 22 | +//! let event = EventBuilderV10::new() |
| 23 | +//! .id(i.to_string()) |
| 24 | +//! .ty("example.test") |
| 25 | +//! .source("localhost") |
| 26 | +//! .extension("ext-name", "AMQP") |
| 27 | +//! .data("application/json", value) |
| 28 | +//! .build() |
| 29 | +//! .unwrap(); |
| 30 | +//! |
| 31 | +//! let event_message = EventMessage::from_binary_event(event).unwrap(); |
| 32 | +//! let message = AmqpMessage::from(event_message); |
| 33 | +//! sender.send(message).await.unwrap() |
| 34 | +//! .accepted_or("not accepted").unwrap(); |
| 35 | +//! |
| 36 | +//! sender.close().await.unwrap(); |
| 37 | +//! session.end().await.unwrap(); |
| 38 | +//! connection.close().await.unwrap(); |
39 | 39 | //! } |
40 | 40 | //! ``` |
41 | 41 | //! |
|
50 | 50 | //! |
51 | 51 | //! #[tokio::main] |
52 | 52 | //! async fn main() { |
53 | | -//! let mut connection = |
54 | | -//! Connection::open("cloudevents-sdk-rust", "amqp://guest:guest@localhost:5672") |
55 | | -//! .await |
56 | | -//! .unwrap(); |
57 | | -//! let mut session = Session::begin(&mut connection).await.unwrap(); |
58 | | -//! let mut receiver = Receiver::attach(&mut session, "receiver", "q1").await.unwrap(); |
59 | | -//! |
60 | | -//! let delivery = receiver.recv().await.unwrap(); |
61 | | -//! receiver.accept(&delivery).await.unwrap(); |
62 | | -//! |
63 | | -//! let event_message = EventMessage::from(delivery.into_message()); |
64 | | -//! let event = MessageDeserializer::into_event(event_message).unwrap(); |
65 | | -//! |
66 | | -//! sender.close().await.unwrap(); |
67 | | -//! session.end().await.unwrap(); |
68 | | -//! connection.close().await.unwrap(); |
| 53 | +//! let mut connection = |
| 54 | +//! Connection::open("cloudevents-sdk-rust", "amqp://guest:guest@localhost:5672") |
| 55 | +//! .await |
| 56 | +//! .unwrap(); |
| 57 | +//! let mut session = Session::begin(&mut connection).await.unwrap(); |
| 58 | +//! let mut receiver = Receiver::attach(&mut session, "receiver", "q1").await.unwrap(); |
| 59 | +//! |
| 60 | +//! let delivery = receiver.recv().await.unwrap(); |
| 61 | +//! receiver.accept(&delivery).await.unwrap(); |
| 62 | +//! |
| 63 | +//! let event_message = EventMessage::from(delivery.into_message()); |
| 64 | +//! let event = MessageDeserializer::into_event(event_message).unwrap(); |
| 65 | +//! |
| 66 | +//! sender.close().await.unwrap(); |
| 67 | +//! session.end().await.unwrap(); |
| 68 | +//! connection.close().await.unwrap(); |
69 | 69 | //! } |
70 | 70 | //! ``` |
71 | 71 |
|
|
0 commit comments