diff --git a/endorser/services/endorsement_processor.py b/endorser/services/endorsement_processor.py
index 28d550614b..40536ffc84 100644
--- a/endorser/services/endorsement_processor.py
+++ b/endorser/services/endorsement_processor.py
@@ -86,7 +86,7 @@ async def _process_endorsement_requests(self) -> NoReturn:
         subscription = await self._subscribe()
         while True:
             try:
-                messages = await subscription.fetch(batch=1, timeout=60, heartbeat=1)
+                messages = await subscription.fetch(batch=1, timeout=2, heartbeat=1)
                 for message in messages:
                     message_subject = message.subject
                     message_data = message.data.decode()