Test 2 second timeout

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()