docs: add nats example

Cargo.toml

@@ -139,3 +139,7 @@ required-features = ["mongo"]
 [[example]]
 name = "openldap"
 required-features = ["openldap"]
+
+[[example]]
+name = "nats"
+required-features = ["nats"]

examples/nats.rs

@@ -0,0 +1,43 @@
+use async_nats::connect;
+use futures::StreamExt;
+use testcontainers_modules::{nats::Nats, testcontainers::runners::AsyncRunner};
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error + 'static>> {
+    // startup the module
+    let node = Nats::default().start().await?;
+
+    // default docker username/password
+    let default_username = "ruser";
+    let default_password = "T0pS3cr3t";
+    let topic = "foo";
+    let port = node.get_host_port_ipv4(4222).await.unwrap();
+
+    // prepare connection string
+    let connection_url = &format!(
+        "nats://{}:{}@127.0.0.1:{}",
+        default_username, default_password, port,
+    );
+
+    let subscriber = connect(connection_url).await.unwrap();
+    let publisher = connect(connection_url).await.unwrap();
+
+    let mut subscription = subscriber.subscribe(topic).await.unwrap();
+
+    println!("sending message");
+    publisher.publish(topic, "Hello".into()).await.unwrap();
+    publisher.publish(topic, "world".into()).await.unwrap();
+
+    let mut messages = Vec::new();
+    while let Some(message) = subscription.next().await {
+        messages.push(message.clone());
+        println!("Received message: {:?}", message);
+        if messages.len() == 2 {
+            break;
+        }
+    }
+
+    assert_eq!(messages.len(), 2);
+    println!("Received {} messages", messages.len());
+    Ok(())
+}

src/lib.rs

@@ -98,7 +98,7 @@ pub mod mssql_server;
 pub mod mysql;
 #[cfg(feature = "nats")]
 #[cfg_attr(docsrs, doc(cfg(feature = "nats")))]
-/// **Nats** (message orineted middleware) testcontainer
+/// **Nats** (message oriented middleware) testcontainer
 pub mod nats;
 #[cfg(feature = "neo4j")]
 #[cfg_attr(docsrs, doc(cfg(feature = "neo4j")))]