diff --git a/waku/node/waku_node.nim b/waku/node/waku_node.nim
index fafce4211..cb712befd 100644
--- a/waku/node/waku_node.nim
+++ b/waku/node/waku_node.nim
@@ -214,9 +214,9 @@ proc mountStoreSync*(
     storeSyncInterval = 300,
     storeSyncRelayJitter = 20,
 ): Future[Result[void, string]] {.async.} =
-  let idsChannel = newAsyncQueue[SyncID](100)
-  let wantsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](100)
-  let needsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](100)
+  let idsChannel = newAsyncQueue[SyncID](0)
+  let wantsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](0)
+  let needsChannel = newAsyncQueue[(PeerId, WakuMessageHash)](0)
 
   var cluster: uint16
   var shards: seq[uint16]
diff --git a/waku/waku_store_sync/reconciliation.nim b/waku/waku_store_sync/reconciliation.nim
index 6a5e7bbd5..80c025140 100644
--- a/waku/waku_store_sync/reconciliation.nim
+++ b/waku/waku_store_sync/reconciliation.nim
@@ -135,10 +135,10 @@ proc processRequest(
       sendPayload.shards = self.shards.toSeq()
 
       for hash in hashToSend:
-        await self.remoteNeedsTx.addLast((conn.peerId, hash))
+        self.remoteNeedsTx.addLastNoWait((conn.peerId, hash))
 
       for hash in hashToRecv:
-        await self.localWantstx.addLast((conn.peerId, hash))
+        self.localWantsTx.addLastNoWait((conn.peerId, hash))
 
       rawPayload = sendPayload.deltaEncode()