pyngus/link.py
def configure(self, target_address, source_address, handler, properties):
        """Assign addresses, properties, etc."""
        self._handler = handler
        self._properties = properties

        dynamic_props = None
        if properties:
            dynamic_props = properties.get("dynamic-node-properties")
            mode = _dist_modes.get(properties.get("distribution-mode"))
            if mode is not None:
                self._pn_link.source.distribution_mode = mode
            mode = _snd_settle_modes.get(properties.get("snd-settle-mode"))
            if mode is not None:
                self._pn_link.snd_settle_mode = mode
            mode = _rcv_settle_modes.get(properties.get("rcv-settle-mode"))
            if mode is not None:
                self._pn_link.rcv_settle_mode = mode

        if target_address is None:
            if not self._pn_link.is_sender:
                raise Exception("Dynamic target not allowed")
            self._pn_link.target.dynamic = True
            if dynamic_props:
                self._pn_link.target.properties.clear()
                self._pn_link.target.properties.put_dict(dynamic_props)
        elif target_address:
            self._pn_link.target.address = target_address

        if source_address is None:
            if not self._pn_link.is_receiver:
                raise Exception("Dynamic source not allowed")
            self._pn_link.source.dynamic = True
            if dynamic_props:
                self._pn_link.source.properties.clear()
                self._pn_link.source.properties.put_dict(dynamic_props)
        elif source_address:
            self._pn_link.source.address = source_address
def configure(self, target_address, source_address, handler, properties):
        self._handler = handler
        self._properties = properties

        dynamic_props = None
        if properties:
            dynamic_props = properties.get("dynamic-node-properties")
            mode = _dist_modes.get(properties.get("distribution-mode"))
            if mode is not None:
                self._pn_link.source.distribution_mode = mode
            mode = _snd_settle_modes.get(properties.get("snd-settle-mode"))
            if mode is not None:
                self._pn_link.snd_settle_mode = mode
            mode = _rcv_settle_modes.get(properties.get("rcv-settle-mode"))
            if mode is not None:
                self._pn_link.rcv_settle_mode = mode

        if target_address is None:
            if not self._pn_link.is_sender:
                raise Exception("Dynamic target not allowed")
            self._pn_link.target.dynamic = True
            if dynamic_props:
                self._pn_link.target.properties.clear()
                self._pn_link.target.properties.put_dict(dynamic_props)
        elif target_address:
            self._pn_link.target.address = target_address

        if source_address is None:
            if not self._pn_link.is_receiver:
                raise Exception("Dynamic source not allowed")
            self._pn_link.source.dynamic = True
            if dynamic_props:
                self._pn_link.source.properties.clear()
                self._pn_link.source.properties.put_dict(dynamic_props)
        elif source_address:
            self._pn_link.source.address = source_address
def configure ( self , target_address , source_address , handler , properties ) : self . _handler = handler self . _properties = properties dynamic_props = None if properties : dynamic_props = properties . get ( "dynamic-node-properties" ) mode = _dist_modes . get ( properties . get ( "distribution-mode" ) ) if mode is not None : self . _pn_link . source . distribution_mode = mode mode = _snd_settle_modes . get ( properties . get ( "snd-settle-mode" ) ) if mode is not None : self . _pn_link . snd_settle_mode = mode mode = _rcv_settle_modes . get ( properties . get ( "rcv-settle-mode" ) ) if mode is not None : self . _pn_link . rcv_settle_mode = mode if target_address is None : if not self . _pn_link . is_sender : raise Exception ( "Dynamic target not allowed" ) self . _pn_link . target . dynamic = True if dynamic_props : self . _pn_link . target . properties . clear ( ) self . _pn_link . target . properties . put_dict ( dynamic_props ) elif target_address : self . _pn_link . target . address = target_address if source_address is None : if not self . _pn_link . is_receiver : raise Exception ( "Dynamic source not allowed" ) self . _pn_link . source . dynamic = True if dynamic_props : self . _pn_link . source . properties . clear ( ) self . _pn_link . source . properties . put_dict ( dynamic_props ) elif source_address : self . _pn_link . source . address = source_address
Assign addresses, properties, etc.
Assign addresses properties etc .