Method get_consumers

st2common/st2common/services/sensor_watcher.py:63–71

(self, Consumer, channel)

        }

    def get_consumers(self, Consumer, channel):
        consumers = [
            Consumer(
                queues=[self._sensor_watcher_q],
                accept=["pickle"],
                callbacks=[self.process_task],
            )
        ]
        return consumers

    def process_task(self, body, message):
        LOG.debug("process_task")