diff --git a/swh/journal/checker.py b/swh/journal/checker.py
index 69d39a4..19ffcf6 100644
--- a/swh/journal/checker.py
+++ b/swh/journal/checker.py
@@ -1,93 +1,95 @@
 # Copyright (C) 2017  The Software Heritage developers
 # See the AUTHORS file at the top-level directory of this distribution
 # License: GNU General Public License version 3, or any later version
 # See top-level LICENSE file for more information
 
 """Module defining journal checker classes.
 
 Those checker goal is to send back all, or missing objects from the
 journal queues.
 
 At the moment, a first naive implementation is the
 SWHSimpleCheckerProducer.  It simply reads the objects from the
 storage and sends every object identifier back to the journal.
 
 """
 
 from kafka import KafkaProducer
 
 from swh.core.config import SWHConfig
 from .backend import Backend
 from .serializers import value_to_kafka
 
 
 SUPPORTED_OBJECT_TYPES = set([
     'origin',
     'content',
     'directory',
     'revision',
     'release',
     'origin_visit',
     'skipped_content',
 ])
 
 
 class SWHJournalSimpleCheckerProducer(SWHConfig):
     """Class in charge of reading the storage's objects and sends those
        back to the publisher queue.
 
        This is designed to be run periodically.
 
     """
     DEFAULT_CONFIG = {
         'brokers': ('list[str]', ['getty.internal.softwareheritage.org']),
-        'writing_prefix': ('str', 'swh.tmp_journal.new'),
+        'temporary_prefix': ('str', 'swh.tmp_journal.new'),
         'publisher_id': ('str', 'swh.journal.publisher.test'),
         'object_types': ('list[str]', ['content', 'revision', 'release']),
         'storage_dbconn': ('str', 'service=swh-dev'),
     }
 
     CONFIG_BASE_FILENAME = 'journal/checker'
 
     def __init__(self, extra_configuration=None):
         self.config = config = self.parse_config_file()
         if extra_configuration:
             config.update(extra_configuration)
 
         self.object_types = self.config['object_types']
         for obj_type in self.object_types:
             if obj_type not in SUPPORTED_OBJECT_TYPES:
                 raise ValueError('The object type %s is not supported. '
                                  'Possible values are %s' % (
                                      obj_type, SUPPORTED_OBJECT_TYPES))
 
         self.storage_backend = Backend(self.config['storage_dbconn'])
 
         self.producer = KafkaProducer(
             bootstrap_servers=config['brokers'],
             value_serializer=value_to_kafka,
             client_id=config['publisher_id'],
         )
 
     def _read_storage(self):
-        """Read all the storage's objects and returns as dict of object_types,
-           set of identifiers.
+        """Read storage's objects and generates tuple as object_type, dict of
+           object.
+
+           Yields:
+               tuple of object_type, object as dict
 
         """
         for obj_type in self.object_types:
             for obj in self.storage_backend.fetch(obj_type):
                 yield obj_type, obj
 
     def run(self):
-        """Reads storage's subscribed object types and send them all back to
-           the publisher queue.
+        """Reads storage's subscribed object types and send them to the
+           publisher's reading queue.
 
         """
-
         for obj_type, obj in self._read_storage():
-            topic = '%s.%s' % (self.config['writing_prefix'], obj_type)
+            topic = '%s.%s' % (self.config['temporary_prefix'], obj_type)
             self.producer.send(topic, value=obj)
 
 
 if __name__ == '__main__':
     SWHJournalSimpleCheckerProducer().run()