azure-servicebus/azure/servicebus/receive_handler.py
def _build_receiver(self):
        """This is a temporary patch pending a fix in uAMQP."""
        # pylint: disable=protected-access
        self._handler.message_handler = self._handler.receiver_type(
            self._handler._session,
            self._handler._remote_address,
            self._handler._name,
            on_message_received=self._handler._message_received,
            name='receiver-link-{}'.format(uuid.uuid4()),
            debug=self._handler._debug_trace,
            prefetch=self._handler._prefetch,
            max_message_size=self._handler._max_message_size,
            properties=self._handler._link_properties,
            error_policy=self._handler._error_policy,
            encoding=self._handler._encoding)
        if self.mode != ReceiveSettleMode.PeekLock:
            self._handler.message_handler.send_settle_mode = constants.SenderSettleMode.Settled
            self._handler.message_handler.receive_settle_mode = constants.ReceiverSettleMode.ReceiveAndDelete
            self._handler.message_handler._settle_mode = constants.ReceiverSettleMode.ReceiveAndDelete
        self._handler.message_handler.open()
def _build_receiver(self):
        # pylint: disable=protected-access
        self._handler.message_handler = self._handler.receiver_type(
            self._handler._session,
            self._handler._remote_address,
            self._handler._name,
            on_message_received=self._handler._message_received,
            name='receiver-link-{}'.format(uuid.uuid4()),
            debug=self._handler._debug_trace,
            prefetch=self._handler._prefetch,
            max_message_size=self._handler._max_message_size,
            properties=self._handler._link_properties,
            error_policy=self._handler._error_policy,
            encoding=self._handler._encoding)
        if self.mode != ReceiveSettleMode.PeekLock:
            self._handler.message_handler.send_settle_mode = constants.SenderSettleMode.Settled
            self._handler.message_handler.receive_settle_mode = constants.ReceiverSettleMode.ReceiveAndDelete
            self._handler.message_handler._settle_mode = constants.ReceiverSettleMode.ReceiveAndDelete
        self._handler.message_handler.open()
def _build_receiver ( self ) : # pylint: disable=protected-access self . _handler . message_handler = self . _handler . receiver_type ( self . _handler . _session , self . _handler . _remote_address , self . _handler . _name , on_message_received = self . _handler . _message_received , name = 'receiver-link-{}' . format ( uuid . uuid4 ( ) ) , debug = self . _handler . _debug_trace , prefetch = self . _handler . _prefetch , max_message_size = self . _handler . _max_message_size , properties = self . _handler . _link_properties , error_policy = self . _handler . _error_policy , encoding = self . _handler . _encoding ) if self . mode != ReceiveSettleMode . PeekLock : self . _handler . message_handler . send_settle_mode = constants . SenderSettleMode . Settled self . _handler . message_handler . receive_settle_mode = constants . ReceiverSettleMode . ReceiveAndDelete self . _handler . message_handler . _settle_mode = constants . ReceiverSettleMode . ReceiveAndDelete self . _handler . message_handler . open ( )
This is a temporary patch pending a fix in uAMQP.
This is a temporary patch pending a fix in uAMQP .