diff --git a/mirror_from_pagure_bus.py b/mirror_from_pagure_bus.py index 8c3ba97..a6dd6eb 100644 --- a/mirror_from_pagure_bus.py +++ b/mirror_from_pagure_bus.py @@ -12,7 +12,7 @@ import subprocess import sys import time -from fedora_messaging import api, config +from fedora_messaging import api, config, message _log = logging.getLogger("mirror_from_pagure_bus") @@ -72,6 +72,11 @@ class MirrorFromPagure(object): _log.info("Ready to consume and trigger on %s", self.trigger_names) + msg = message.Message + msg.topic = "io.pagure.prod.pagure.git.receive" + msg.body = {"repo": {"fullname": self.trigger_names[0]}} + self.__call__(message=msg) + def __call__(self, message, cnt=0): """ Invoked when a message is received by the consumer.