fe2o3-amqp-ws

WebSocket adapter for AMQP 1.0 websocket binding

This provides a thin wrapper over tokio_tungstenite::WebSocketStream, and the wrapper performs the WebSocket handshake with the "Sec-WebSocket-Protocol" HTTP header set to "amqp".

The wrapper type [WebSocketStream] could also be used for non-AMQP applications; however, the user should establish websocket stream with raw tokio_tungstenite API and then wrap the stream with the wrapper by fe2o3_amqp_ws::WebSocketStream::from(ws_stream).

Feature flags

toml default = []

| Feature | Description | |---------|-------------| | native-tls | Enables "tokio-tungstenite/native-tls" | | native-tls-vendored | Enables "tokio-tungstenite/native-tls-vendored" | | rustls-tls-native-roots | Enables "tokio-tungstenite/rustls-tls-native-roots" | | rustls-tls-webpki-roots | Enables "tokio-tungstenite/rustls-tls-webpki-roots" |

Example

```rust use fe2o3amqp::{ types::{messaging::Outcome, primitives::Value}, Connection, Delivery, Receiver, Sender, Session, }; use fe2o3amqp_ws::WebSocketStream;

[tokio::main]

async fn main() { let wsstream = WebSocketStream::connect("ws://localhost:5673") .await .unwrap(); let mut connection = Connection::builder() .containerid("connection-1") .openwithstream(ws_stream) .await .unwrap(); let mut session = Session::begin(&mut connection).await.unwrap();

let mut sender = Sender::attach(&mut session, "rust-sender-link-1", "q1")
    .await
    .unwrap();
let mut receiver = Receiver::attach(&mut session, "rust-recver-1", "q1")
    .await
    .unwrap();

let fut = sender.send_batchable("hello batchable AMQP").await.unwrap();

let delivery: Delivery<Value> = receiver.recv().await.unwrap();
receiver.accept(&delivery).await.unwrap();

let outcome: Outcome = fut.await.unwrap();
outcome.accepted_or_else(|state| state).unwrap(); // Handle delivery outcome

sender.close().await.unwrap();
receiver.close().await.unwrap();
session.end().await.unwrap();
connection.close().await.unwrap();

} ```

WebAssembly support

Experimental support for wasm32-unknown-unknown target has been added since "0.3.0" and uses a web_sys::WebSocket internally. An example of this can be found in examples/wasm32-in-browser.

License: MIT/Apache-2.0