azure-servicebus/azure/servicebus/aio/async_utils.py
def register(self, renewable, timeout=300):
        """Register a renewable entity for automatic lock renewal.

        :param renewable: A locked entity that needs to be renewed.
        :type renewable: ~azure.servicebus.aio.async_message.Message or
         ~azure.servicebus.aio.async_receive_handler.SessionReceiver
        :param timeout: A time in seconds that the lock should be maintained for.
         Default value is 300 (5 minutes).
        :type timeout: int
        """
        starttime = renewable_start_time(renewable)
        renew_future = asyncio.ensure_future(self._auto_lock_renew(renewable, starttime, timeout), loop=self.loop)
        self._futures.append(renew_future)
def register(self, renewable, timeout=300):
        """Register a renewable entity for automatic lock renewal.

        :param renewable: A locked entity that needs to be renewed.
        :type renewable: ~azure.servicebus.aio.async_message.Message or
         ~azure.servicebus.aio.async_receive_handler.SessionReceiver
        :param timeout: A time in seconds that the lock should be maintained for.
         Default value is 300 (5 minutes).
        :type timeout: int
        """
        starttime = renewable_start_time(renewable)
        renew_future = asyncio.ensure_future(self._auto_lock_renew(renewable, starttime, timeout), loop=self.loop)
        self._futures.append(renew_future)
Register a renewable entity for automatic lock renewal.

        :param renewable: A locked entity that needs to be renewed.
        :type renewable: ~azure.servicebus.aio.async_message.Message or
         ~azure.servicebus.aio.async_receive_handler.SessionReceiver
        :param timeout: A time in seconds that the lock should be maintained for.
         Default value is 300 (5 minutes).
        :type timeout: int