ternya/ternya.py
def init_neutron_consumer(self, mq):
        """
        Init openstack neutron mq

        1. Check if enable listening neutron notification
        2. Create consumer

        :param mq: class ternya.mq.MQ
        """
        if not self.enable_component_notification(Openstack.Neutron):
            log.debug("disable listening neutron notification")
            return

        for i in range(self.config.neutron_mq_consumer_count):
            mq.create_consumer(self.config.neutron_mq_exchange,
                               self.config.neutron_mq_queue,
                               ProcessFactory.process(Openstack.Neutron))

        log.debug("enable listening openstack neutron notification.")
def init_neutron_consumer(self, mq):
        """
        Init openstack neutron mq

        1. Check if enable listening neutron notification
        2. Create consumer

        :param mq: class ternya.mq.MQ
        """
        if not self.enable_component_notification(Openstack.Neutron):
            log.debug("disable listening neutron notification")
            return

        for i in range(self.config.neutron_mq_consumer_count):
            mq.create_consumer(self.config.neutron_mq_exchange,
                               self.config.neutron_mq_queue,
                               ProcessFactory.process(Openstack.Neutron))

        log.debug("enable listening openstack neutron notification.")
def init_neutron_consumer ( self , mq ) : if not self . enable_component_notification ( Openstack . Neutron ) : log . debug ( "disable listening neutron notification" ) return for i in range ( self . config . neutron_mq_consumer_count ) : mq . create_consumer ( self . config . neutron_mq_exchange , self . config . neutron_mq_queue , ProcessFactory . process ( Openstack . Neutron ) ) log . debug ( "enable listening openstack neutron notification." )
Init openstack neutron mq

        1. Check if enable listening neutron notification
        2. Create consumer

        :param mq: class ternya.mq.MQ
Init openstack neutron mq