before_script:
  - echo "The SERVICE_HOST is:" $SERVICE_HOST

    def publish(self, queue: str, msg: dict, repeat: int = 1, delay: float = 0.):
        properties = {'content_type': 'application/json'}
        exchange, rkey = queue.split('/') if '/' in queue else ("", queue)

        event = {
            "Body": msg.get("Body") or msg
        }

        body = json.dumps(event).encode()

        exchange = rabbitpy.Exchange(self._channel, exchange)
        message = rabbitpy.Message(self._channel, body, properties)

        for _ in range(repeat):
            message.publish(exchange, rkey)
            dlog("RabbitMQ publish to exchange \"%s\" with routing key \"%s\": %s", exchange, rkey, event)
            time.sleep(delay)