diff --git a/src/subscriptions.c b/src/subscriptions.c
index 51d7e886..900559fd 100644
--- a/src/subscriptions.c
+++ b/src/subscriptions.c
@@ -185,6 +185,7 @@ subscription_reschedule(void)
   streaming_message_t *sm;
   int error;
   if (reenter) return;
+  reenter = 1;
 
   lock_assert(&global_lock);