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 BunBunClient {
+pub struct AMQPClient {
     conn: Connection,
 }
 
-impl BunBunClient {
+impl AMQPClient {
     /// Creates an rpc client
     ///
     /// # Examples

src/lib.rs

@@ -16,10 +16,10 @@ use std::{
     sync::Arc,
 };
 use tokio::sync::Mutex;
-pub mod client;
+mod client;
 mod test;
 
-pub struct BunBunWorker {
+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::{BunBunClient, RPCClientTask},
+        client::{AMQPClient, RPCClientTask},
         BunBunWorker, RPCServerTask,
     };
 
@@ -117,7 +117,7 @@ mod test {
     #[traced_test]
     async fn rpc_client() {
         //
-        let mut client = BunBunClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
+        let mut client = AMQPClient::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 = BunBunClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
+        let mut client = AMQPClient::new(env::var("AMQP_SERVER_URL").unwrap().as_str())
             .await
             .unwrap();
         let client = Arc::new(Mutex::new(client));