diff --git a/endorser/services/endorsement_processor.py b/endorser/services/endorsement_processor.py index 11845de37..78887804f 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=1, heartbeat=0.5) + messages = await subscription.fetch(batch=1, timeout=1, heartbeat=0.4) for message in messages: message_subject = message.subject message_data = message.data.decode()