diff --git a/src/bussy/mod.rs b/src/bussy/mod.rs
index 147d5d9..738293d 100644
--- a/src/bussy/mod.rs
+++ b/src/bussy/mod.rs
@@ -112,7 +112,7 @@ impl PubSub {
     }
 
     pub async fn subscribe(&self, topic: &str) -> broadcast::Receiver<Message> {
-        let (tx, _rx) = broadcast::channel(256); // 256 is the channel capacity
+        let (tx, _rx) = broadcast::channel(20_000); // 20000 is the channel capacity
         let mut subscribers = self.subscribers.lock().await;
         subscribers
             .entry(topic.to_string())