changes: made client public,

also renamed client  AMQPWorker -> BunBunClient

src/client.rs

@@ -18,11 +18,11 @@ use crate::ResultHeader;
 /// With this client you can send messages to a queue that other microservices
 /// will process
 #[derive(Debug)]
-pub struct AMQPClient {
+pub struct BunBunClient {
     conn: Connection,
 }
 
-impl AMQPClient {
+impl BunBunClient {
     /// Creates an rpc client
     ///
     /// # Examples

src/lib.rs

@@ -16,10 +16,10 @@ use std::{
     sync::Arc,
 };
 use tokio::sync::Mutex;
-mod client;
+pub mod client;
 mod test;
 
-struct BunBunWorker {
+pub struct BunBunWorker {
     channel: Channel,
     consumers: Vec<Consumer>,
     handlers: Vec<

src/test/mod.rs

@@ -10,7 +10,7 @@ mod test {
     use tracing_test::traced_test;
 
     use crate::{
-        client::{AMQPClient, RPCClientTask},
+        client::{BunBunClient, RPCClientTask},
         BunBunWorker, RPCServerTask,
     };
 
@@ -117,7 +117,7 @@ mod test {
     #[traced_test]
     async fn rpc_client() {
         //
-        let mut client = AMQPClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
+        let mut client = BunBunClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
             .await
             .unwrap();
         let result = client
@@ -142,7 +142,7 @@ mod test {
     #[traced_test]
     async fn rpc_client_spam_multithread() {
         //
-        let mut client = AMQPClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
+        let mut client = BunBunClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
             .await
             .unwrap();
         let client = Arc::new(Mutex::new(client));