Merge lp:~pwlars/snappy-proposed-selftest-agent/rename-agent-code into lp:snappy-proposed-selftest-agent

[Paul Larson]

Rename core-selftest-agent to snappy-proposed-selftest-agent.

Rename core-selftest-agent to snappy-proposed-selftest-agent. I've left behind some worker names like CoreSelftestWorker and such as they are internal and will be getting worked on soon as other MPs anyway. Same for queue names which still need some tweaking.

[Para Siva (psivaa)]

+1, Thanks for the comment about the worker code as incoming MPs

review: Approve

[lp:~pwlars/snappy-proposed-selftest-agent/rename-agent-code]

8. By Paul Larson on 2015-05-27

add back snappy-proposed-selftest-agent.py and snappy_proposed_selftest_agent/

[Paul Larson (pwlars)]

argh, I forgot to do bzr before the mv when renaming the module and the cli. I've just added them back, which makes this a bit long, but it's just a rename and s/core-/snappy-proposed/ for the most part. If you need me to start over for this to make sense, just say so.

review: Needs Resubmitting

[Para Siva (psivaa)]

Thanks for adding the worker code, Paul. I've got some inline comments about the queue names etc, since we're renaming. Let me know if they dont make sense.

review: Needs Fixing

[lp:~pwlars/snappy-proposed-selftest-agent/rename-agent-code]

9. By Paul Larson on 2015-05-27

change conf file name

10. By Paul Larson on 2015-05-27

Add .v1 to exchanges as discussed

[Paul Larson (pwlars)]

I was going to handle the exchange .v1 addition we discussed this morning in a separate mp, but no good reason not to do it here. Also change the .conf file name as is being done elsewhere.

review: Needs Resubmitting

[Para Siva (psivaa)]

Thanks for that. +1

review: Approve

=== modified file 'README.rst'
--- README.rst	2015-05-20 22:00:00 +0000
+++ README.rst	2015-05-27 17:01:56 +0000
@@ -1,10 +1,10 @@
-Core Selftest Agent
-###################
+Snappy Proposed Selftest Agent
+##############################
 
 A micro-service that watches for britney-announcer events of new
 packages to test, checks if they are in the manifest for core images in
-the channel we want to test, and triggers core-image-builder to start
-building an image with the proposed changes. This service is only
+the channel we want to test, and triggers snappy-proposed-image-builder 
+to start building an image with the proposed changes. This service is only
 responsible for triggering test runs of the snappy selftests.
 
 Get the Source
@@ -12,7 +12,7 @@
 
 Branch the code::
 
-  $ bzr branch lp:core-selftest-agent
+  $ bzr branch lp:snappy-proposed-selftest-agent
 
 Install the Service
 ===================

=== modified file 'called-by-tarmac.py'
--- called-by-tarmac.py	2015-05-22 16:26:11 +0000
+++ called-by-tarmac.py	2015-05-27 17:01:56 +0000
@@ -1,6 +1,6 @@
 #!/usr/bin/env python3
 #
-# core-selftest-agent
+# snappy-proposed-selftest-agent
 # Copyright (C) 2015 Canonical
 #
 # This program is free software: you can redistribute it and/or modify
@@ -33,7 +33,7 @@
 import sys
 import tempfile
 
-SERVICE_NAME = 'core-selftest-agent'
+SERVICE_NAME = 'snappy-proposed-selftest-agent'
 VENV_DIR = 'venv-{}'.format(SERVICE_NAME)
 PIP_DIR = 'pip-cache-'.format(SERVICE_NAME)
 PIP_CACHE_BRANCH = 'lp:~canonical-ci-engineering/{}/' \

=== removed file 'core-selftest-agent.py'
--- core-selftest-agent.py	2015-05-20 17:20:50 +0000
+++ core-selftest-agent.py	1970-01-01 00:00:00 +0000
@@ -1,7 +0,0 @@
-#!/usr/bin/env python3
-
-from core_selftest_agent import main
-
-
-if __name__ == '__main__':
-        main()

=== removed directory 'core_selftest_agent'
=== removed file 'core_selftest_agent/__init__.py'
--- core_selftest_agent/__init__.py	2015-05-22 19:49:10 +0000
+++ core_selftest_agent/__init__.py	1970-01-01 00:00:00 +0000
@@ -1,116 +0,0 @@
-# core-selftest-agent
-# Copyright (C) 2015 Canonical
-#
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <http://www.gnu.org/licenses/>.
-#
-
-import argparse
-import configparser
-import kombu
-import logging
-import os
-
-from uservice_utils.logging import (
-    configure_service_logging,
-    ExtraLogger,
-)
-
-from core_selftest_agent import constants
-from core_selftest_agent.worker import CoreSelftestAgentWorker
-
-
-class CoreImageResultPublisher(object):
-    """A callable that can notify a results exchange that the test is running
-
-    This will be a fanout exchange so multiple consumers can pick up these
-    messages and decide whether to take action or ignore them.
-    """
-
-    def __init__(self, connection):
-        self.connection = connection
-        exchange = kombu.Exchange(constants.RESULTS_EXCHANGE,
-                                  type='fanout', durable=False)
-        self.queue = kombu.Queue(constants.RESULTS_QUEUE, exchange)
-
-    def __call__(self, payload):
-        """Take 'payload' and enqueue it on the rabbit exchange."""
-        queue = self.connection.SimpleQueue(self.queue)
-        queue.put(payload)
-        queue.close()
-
-
-class CoreImageBuilder(object):
-    """A callable that knows how to queue message for the image builder
-
-    For now we're using a simple queue, but this can easily be extended to use
-    a full-blown topic exchange in the future.
-    """
-
-    def __init__(self, connection):
-        self.connection = connection
-
-    def __call__(self, payload):
-        """Take 'payload' and enqueue it on the rabbit queue."""
-        queue = self.connection.SimpleQueue(constants.IMAGE_BUILD_QUEUE)
-        queue.put(payload)
-        queue.close()
-
-
-def read_config():
-    parser = argparse.ArgumentParser(description='Core Selftest Agent.')
-    parser.add_argument(
-        '-c',
-        '--conf',
-        default='core-service.conf',
-        help='Configuration file path'
-    )
-    args = parser.parse_args()
-
-    # Load configuration options.
-    config = configparser.ConfigParser()
-    config.read(args.conf)
-    return config
-
-
-def get_logger(name, extra={}):
-    if logging.getLoggerClass() != ExtraLogger:
-        logging.setLoggerClass(ExtraLogger)
-    logger = logging.getLogger(name)
-    e = constants.LOGGING_EXTRA.copy()
-    e.update(extra)
-    logger.set_extra_args(e)
-    return logger
-
-
-def main():
-    config = read_config()
-    log_path = os.path.abspath(
-        os.path.join(__file__, '../../logs/core-selftest-agent.log'))
-    configure_service_logging(
-        log_path,
-        config['logstash'] if 'logstash' in config else None
-    )
-
-    ampq_uris = config.get('amqp', 'uris').split()
-    try:
-        with kombu.Connection(ampq_uris) as connection:
-            monitor = CoreSelftestAgentWorker(
-                connection,
-                constants,
-                CoreImageBuilder(connection),
-                CoreImageResultPublisher(connection),
-            )
-            monitor.run()
-    except KeyboardInterrupt:
-        print("Bye!")

=== removed file 'core_selftest_agent/constants.py'
--- core_selftest_agent/constants.py	2015-05-26 14:57:41 +0000
+++ core_selftest_agent/constants.py	1970-01-01 00:00:00 +0000
@@ -1,49 +0,0 @@
-# core-selftest-agent
-# Copyright (C) 2015 Canonical
-#
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <http://www.gnu.org/licenses/>.
-#
-
-"""Constants for this service."""
-import socket
-
-# Queue names are constant, rather than being defined in the config.
-
-# We listen to a fanout exchange for candidate packages to test
-INPUT_EXCHANGE = "candidates.exchange"
-
-# The queue needs to be unique to selftest agents
-INPUT_QUEUE = "core.selftest.candidates"
-
-# The queue we send events on to request image build and test
-IMAGE_BUILD_QUEUE = "snappy-proposed-migration.package.v1"
-
-# We need to notify the results exchange that the test is in progress
-RESULTS_EXCHANGE = "results.exchange"
-RESULTS_QUEUE = "core.selftest.results"
-
-# The queue we put fatally error'd payloads into:
-DEAD_LETTER_QUEUE = "core.deadletters.v1"
-
-SOLUTION_NAME = "core-image-testing"
-
-SERVICE_NAME = "core-selftest-agent"
-
-HOSTNAME = socket.gethostname()
-
-LOGGING_EXTRA = {
-    'solution': SOLUTION_NAME,
-    'service': SERVICE_NAME,
-    'hostname': HOSTNAME,
-}

=== removed directory 'core_selftest_agent/tests'
=== removed file 'core_selftest_agent/tests/__init__.py'
--- core_selftest_agent/tests/__init__.py	2015-05-22 19:49:10 +0000
+++ core_selftest_agent/tests/__init__.py	1970-01-01 00:00:00 +0000
@@ -1,16 +0,0 @@
-# core-selftest-agent
-# Copyright (C) 2015 Canonical
-#
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <http://www.gnu.org/licenses/>.
-#

=== removed file 'core_selftest_agent/tests/test_worker.py'
--- core_selftest_agent/tests/test_worker.py	2015-05-26 14:57:41 +0000
+++ core_selftest_agent/tests/test_worker.py	1970-01-01 00:00:00 +0000
@@ -1,53 +0,0 @@
-# core-selftest-agent
-# Copyright (C) 2015 Canonical
-#
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <http://www.gnu.org/licenses/>.
-#
-
-import kombu
-from testtools import TestCase
-
-from core_selftest_agent import constants
-from core_selftest_agent.worker import CoreSelftestAgentWorker
-
-
-class WorkerTests(TestCase):
-    def test_can_read_message(self):
-        conn = kombu.Connection('memory:///')
-        queue_message(conn, {'test': 'value'})
-
-        build_worker = LoggingConsumer()
-        result_worker = LoggingConsumer()
-        q = CoreSelftestAgentWorker(conn, constants,
-                                    build_worker, result_worker)
-        next(q.consume(limit=1, timeout=5.0))
-        self.assertEqual(build_worker.messages_seen, [dict(test='value')])
-        self.assertEqual(result_worker.messages_seen, [dict(test='value')])
-
-
-class LoggingConsumer(object):
-    """A consumer callback object that acks and logs all received payloads."""
-    def __init__(self):
-        self.messages_seen = []
-
-    def __call__(self, message):
-        self.messages_seen.append(message)
-
-
-def queue_message(conn, message):
-    exchange = kombu.Exchange(constants.INPUT_EXCHANGE,
-                              type='fanout', durable=False)
-    queue = kombu.Queue(constants.INPUT_QUEUE, exchange)
-    with conn.SimpleQueue(queue) as q:
-        q.put(message)

=== removed file 'core_selftest_agent/worker.py'
--- core_selftest_agent/worker.py	2015-05-22 19:49:10 +0000
+++ core_selftest_agent/worker.py	1970-01-01 00:00:00 +0000
@@ -1,52 +0,0 @@
-# core-selftest-agent
-# Copyright (C) 2015 Canonical
-#
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <http://www.gnu.org/licenses/>.
-#
-
-import kombu
-
-from kombu.mixins import ConsumerMixin
-
-
-class CoreSelftestAgentWorker(ConsumerMixin):
-
-    def __init__(self, connection, config, build_worker, result_worker):
-        self.config = config
-        self.connection = connection
-        self.build_worker = build_worker
-        self.result_worker = result_worker
-
-        exchange = kombu.Exchange(self.config.INPUT_EXCHANGE,
-                                  type='fanout', durable=False)
-        self.queue = kombu.Queue(self.config.INPUT_QUEUE, exchange)
-
-    def get_consumers(self, Consumer, channel):
-        """Return consumers instances for all configured queues."""
-        queues = [self.queue]
-        return [kombu.Consumer(
-            channel, queues=queues, callbacks=[self.process])]
-
-    def process(self, body, message):
-        """ Process incoming messages about candidate packages
-
-        TODO: Check if we care about this package, if so, send a message
-        to the image builder to create the image and start the tests, and
-        a message to the results exchange to mark it as in progress.
-
-        For now, just blindly post messages for these
-        """
-
-        self.build_worker(body)
-        self.result_worker(body)

=== modified file 'setup.py'
--- setup.py	2015-05-22 19:49:10 +0000
+++ setup.py	2015-05-27 17:01:56 +0000
@@ -1,6 +1,6 @@
 #!/usr/bin/env python3
 
-# core-selftest-agent
+# snappy-proposed-selftest-agent
 # Copyright (C) 2015 Canonical
 #
 # This program is free software: you can redistribute it and/or modify
@@ -27,15 +27,15 @@
 
 
 setup(
-    name='core-selftest-agent',
+    name='snappy-proposed-selftest-agent',
     version=VERSION,
-    description=('A microservice for triggering snappy selftest on changes to '
-                 'core packages.'),
+    description=('A microservice for triggering snappy selftest on changes '
+                 'to core packages.'),
     author='Canonical CI Engineering Team',
     author_email='[e-mail]',
-    url='https://launchpad.net/core-selftest-agent',
+    url='https://launchpad.net/snappy-proposed-selftest-agent',
     license='GPLv3',
     packages=find_packages(),
-    scripts=['core-selftest-agent.py'],
-    test_suite='core_selftest_agent.tests',
+    scripts=['snappy-proposed-selftest-agent.py'],
+    test_suite='snappy_proposed_selftest_agent.tests',
 )

=== added file 'snappy-proposed-selftest-agent.py'
--- snappy-proposed-selftest-agent.py	1970-01-01 00:00:00 +0000
+++ snappy-proposed-selftest-agent.py	2015-05-27 17:01:56 +0000
@@ -0,0 +1,7 @@
+#!/usr/bin/env python3
+
+from snappy_proposed_selftest_agent import main
+
+
+if __name__ == '__main__':
+        main()

=== added directory 'snappy_proposed_selftest_agent'
=== added file 'snappy_proposed_selftest_agent/__init__.py'
--- snappy_proposed_selftest_agent/__init__.py	1970-01-01 00:00:00 +0000
+++ snappy_proposed_selftest_agent/__init__.py	2015-05-27 17:01:56 +0000
@@ -0,0 +1,117 @@
+# snappy-proposed-selftest-agent
+# Copyright (C) 2015 Canonical
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+
+import argparse
+import configparser
+import kombu
+import logging
+import os
+
+from uservice_utils.logging import (
+    configure_service_logging,
+    ExtraLogger,
+)
+
+from snappy_proposed_selftest_agent import constants
+from snappy_proposed_selftest_agent.worker import CoreSelftestAgentWorker
+
+
+class CoreImageResultPublisher(object):
+    """A callable that can notify a results exchange that the test is running
+
+    This will be a fanout exchange so multiple consumers can pick up these
+    messages and decide whether to take action or ignore them.
+    """
+
+    def __init__(self, connection):
+        self.connection = connection
+        exchange = kombu.Exchange(constants.RESULTS_EXCHANGE,
+                                  type='fanout', durable=False)
+        self.queue = kombu.Queue(constants.RESULTS_QUEUE, exchange)
+
+    def __call__(self, payload):
+        """Take 'payload' and enqueue it on the rabbit exchange."""
+        queue = self.connection.SimpleQueue(self.queue)
+        queue.put(payload)
+        queue.close()
+
+
+class CoreImageBuilder(object):
+    """A callable that knows how to queue message for the image builder
+
+    For now we're using a simple queue, but this can easily be extended to use
+    a full-blown topic exchange in the future.
+    """
+
+    def __init__(self, connection):
+        self.connection = connection
+
+    def __call__(self, payload):
+        """Take 'payload' and enqueue it on the rabbit queue."""
+        queue = self.connection.SimpleQueue(constants.IMAGE_BUILD_QUEUE)
+        queue.put(payload)
+        queue.close()
+
+
+def read_config():
+    parser = argparse.ArgumentParser(description='Core Selftest Agent.')
+    parser.add_argument(
+        '-c',
+        '--conf',
+        default='snappy-proposed-service.conf',
+        help='Configuration file path'
+    )
+    args = parser.parse_args()
+
+    # Load configuration options.
+    config = configparser.ConfigParser()
+    config.read(args.conf)
+    return config
+
+
+def get_logger(name, extra={}):
+    if logging.getLoggerClass() != ExtraLogger:
+        logging.setLoggerClass(ExtraLogger)
+    logger = logging.getLogger(name)
+    e = constants.LOGGING_EXTRA.copy()
+    e.update(extra)
+    logger.set_extra_args(e)
+    return logger
+
+
+def main():
+    config = read_config()
+    log_path = os.path.abspath(
+        os.path.join(__file__,
+                     '../../logs/snappy-proposed-selftest-agent.log'))
+    configure_service_logging(
+        log_path,
+        config['logstash'] if 'logstash' in config else None
+    )
+
+    ampq_uris = config.get('amqp', 'uris').split()
+    try:
+        with kombu.Connection(ampq_uris) as connection:
+            monitor = CoreSelftestAgentWorker(
+                connection,
+                constants,
+                CoreImageBuilder(connection),
+                CoreImageResultPublisher(connection),
+            )
+            monitor.run()
+    except KeyboardInterrupt:
+        print("Bye!")

=== added file 'snappy_proposed_selftest_agent/constants.py'
--- snappy_proposed_selftest_agent/constants.py	1970-01-01 00:00:00 +0000
+++ snappy_proposed_selftest_agent/constants.py	2015-05-27 17:01:56 +0000
@@ -0,0 +1,49 @@
+# snappy-proposed-selftest-agent
+# Copyright (C) 2015 Canonical
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+
+"""Constants for this service."""
+import socket
+
+# Queue names are constant, rather than being defined in the config.
+
+# We listen to a fanout exchange for candidate packages to test
+INPUT_EXCHANGE = "candidates.exchange.v1"
+
+# The queue needs to be unique to selftest agents
+INPUT_QUEUE = "core.selftest.candidates"
+
+# The queue we send events on to request image build and test
+IMAGE_BUILD_QUEUE = "snappy-proposed-migration.package.v1"
+
+# We need to notify the results exchange that the test is in progress
+RESULTS_EXCHANGE = "results.exchange.v1"
+RESULTS_QUEUE = "core.selftest.results"
+
+# The queue we put fatally error'd payloads into:
+DEAD_LETTER_QUEUE = "core.deadletters.v1"
+
+SOLUTION_NAME = "snappy-proposed-image-testing"
+
+SERVICE_NAME = "snappy-proposed-selftest-agent"
+
+HOSTNAME = socket.gethostname()
+
+LOGGING_EXTRA = {
+    'solution': SOLUTION_NAME,
+    'service': SERVICE_NAME,
+    'hostname': HOSTNAME,
+}

=== added directory 'snappy_proposed_selftest_agent/tests'
=== added file 'snappy_proposed_selftest_agent/tests/__init__.py'
--- snappy_proposed_selftest_agent/tests/__init__.py	1970-01-01 00:00:00 +0000
+++ snappy_proposed_selftest_agent/tests/__init__.py	2015-05-27 17:01:56 +0000
@@ -0,0 +1,16 @@
+# snappy-proposed-selftest-agent
+# Copyright (C) 2015 Canonical
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#

=== added file 'snappy_proposed_selftest_agent/tests/test_worker.py'
--- snappy_proposed_selftest_agent/tests/test_worker.py	1970-01-01 00:00:00 +0000
+++ snappy_proposed_selftest_agent/tests/test_worker.py	2015-05-27 17:01:56 +0000
@@ -0,0 +1,53 @@
+# snappy-proposed-selftest-agent
+# Copyright (C) 2015 Canonical
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+
+import kombu
+from testtools import TestCase
+
+from snappy_proposed_selftest_agent import constants
+from snappy_proposed_selftest_agent.worker import CoreSelftestAgentWorker
+
+
+class WorkerTests(TestCase):
+    def test_can_read_message(self):
+        conn = kombu.Connection('memory:///')
+        queue_message(conn, {'test': 'value'})
+
+        build_worker = LoggingConsumer()
+        result_worker = LoggingConsumer()
+        q = CoreSelftestAgentWorker(conn, constants,
+                                    build_worker, result_worker)
+        next(q.consume(limit=1, timeout=5.0))
+        self.assertEqual(build_worker.messages_seen, [dict(test='value')])
+        self.assertEqual(result_worker.messages_seen, [dict(test='value')])
+
+
+class LoggingConsumer(object):
+    """A consumer callback object that acks and logs all received payloads."""
+    def __init__(self):
+        self.messages_seen = []
+
+    def __call__(self, message):
+        self.messages_seen.append(message)
+
+
+def queue_message(conn, message):
+    exchange = kombu.Exchange(constants.INPUT_EXCHANGE,
+                              type='fanout', durable=False)
+    queue = kombu.Queue(constants.INPUT_QUEUE, exchange)
+    with conn.SimpleQueue(queue) as q:
+        q.put(message)

=== added file 'snappy_proposed_selftest_agent/worker.py'
--- snappy_proposed_selftest_agent/worker.py	1970-01-01 00:00:00 +0000
+++ snappy_proposed_selftest_agent/worker.py	2015-05-27 17:01:56 +0000
@@ -0,0 +1,52 @@
+# snappy-proposed-selftest-agent
+# Copyright (C) 2015 Canonical
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+
+import kombu
+
+from kombu.mixins import ConsumerMixin
+
+
+class CoreSelftestAgentWorker(ConsumerMixin):
+
+    def __init__(self, connection, config, build_worker, result_worker):
+        self.config = config
+        self.connection = connection
+        self.build_worker = build_worker
+        self.result_worker = result_worker
+
+        exchange = kombu.Exchange(self.config.INPUT_EXCHANGE,
+                                  type='fanout', durable=False)
+        self.queue = kombu.Queue(self.config.INPUT_QUEUE, exchange)
+
+    def get_consumers(self, Consumer, channel):
+        """Return consumers instances for all configured queues."""
+        queues = [self.queue]
+        return [kombu.Consumer(
+            channel, queues=queues, callbacks=[self.process])]
+
+    def process(self, body, message):
+        """ Process incoming messages about candidate packages
+
+        TODO: Check if we care about this package, if so, send a message
+        to the image builder to create the image and start the tests, and
+        a message to the results exchange to mark it as in progress.
+
+        For now, just blindly post messages for these
+        """
+
+        self.build_worker(body)
+        self.result_worker(body)