~cprov/uci-engine/boottest-probe

Image watcher to trigger the workflow for when a new image available in http://cloud-images.ubuntu.com/ [r=Paul Larson, Celso Providelo]

added added

removed removed

# Ubuntu CI Engine

# This program is free software: you can redistribute it and/or modify it

# under the terms of the GNU Affero General Public License version 3, as

# published by the Free Software Foundation.

# This program is distributed in the hope that it will be useful, but

# WITHOUT ANY WARRANTY; without even the implied warranties of

# MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR

# PURPOSE. See the GNU Affero General Public License for more details.

# You should have received a copy of the GNU Affero General Public License

# along with this program. If not, see <http://www.gnu.org/licenses/>.

import json

from ci_utils import amqp_utils

class PublisherQueue(object):

"""A proxy to the queue library.

This implementation targets ci_utils/amqp_utils but can be replaced for

tests.

"""

def __init__(self, queue_name):

self.queue_name = queue_name

def publish(self, msg):

amqp_utils.send(self.queue_name, json.dumps(msg),

raise_errors=True)