diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt
index 0e9076d65..65da60dbd 100644
--- a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt
+++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt
@@ -1188,7 +1188,7 @@ class Account(
                         replyingToHex = event.id,
                         authSigner = signer,
                     )
-                wcListener.start()
+                wcListener.startSync()
 
                 LocalCache.consume(event, zappedNote) { it.response(signer) { onResponse(it) } }
 
diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/LocalCache.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/LocalCache.kt
index 97c23bf5d..492f691e2 100644
--- a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/LocalCache.kt
+++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/LocalCache.kt
@@ -1664,7 +1664,10 @@ object LocalCache {
     @Suppress("UNUSED_PARAMETER")
     fun consume(event: ChannelMuteUserEvent) {}
 
-    fun consume(event: LnZapEvent) {
+    fun consume(
+        event: LnZapEvent,
+        relay: Relay?,
+    ) {
         val note = getOrCreateNote(event.id)
         // Already processed this event.
         if (note.event != null) return
@@ -2693,7 +2696,7 @@ object LocalCache {
                     event.zapRequest?.let {
                         // must have a valid request
                         verifyAndConsume(it, relay)
-                        consume(event)
+                        consume(event, relay)
                     }
                 }
                 is LnZapRequestEvent -> consume(event)
diff --git a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/NostrDataSource.kt b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/NostrDataSource.kt
index b3280e4cf..44e8a2df0 100644
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/NostrDataSource.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/NostrDataSource.kt
@@ -157,6 +157,12 @@ abstract class NostrDataSource(
         resetFilters()
     }
 
+    open fun startSync() {
+        Log.d("DataSource", "${this.javaClass.simpleName} Start")
+        active = true
+        resetFiltersSuspend()
+    }
+
     @OptIn(DelicateCoroutinesApi::class)
     open fun stop() {
         active = false