Method get_consumers

st2common/st2common/services/triggerwatcher.py:82–89

(self, Consumer, channel)

        }

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

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