@@ -0,0 +1,1040 @@
+# -*- test-case-name: tests.test_ttc -*-%0A%0Afrom twisted.internet.defer import Deferred, inlineCallbacks%0A%0Aimport pymongo%0A%0Afrom vumi.service import Worker%0Afrom vumi.message import TransportUserMessage%0Afrom vumi import log%0A%0A%0Aclass GarbageWorker(Worker):%0A    %0A    @inlineCallbacks%0A    def startWorker(self):%0A        log.msg(%22Garbage Worker is starting%22)%0A%0A        connection = pymongo.Connection('localhost', 27017)%0A        self.db = connection%5B'vusion'%5D%0A        if not 'unmatchable_reply' in self.db.collection_names():%0A            self.db.create_collection('unmatchable_reply')%0A        self.unmatchable_reply_collection = self.db%5B'unmatchable_reply'%5D%0A%0A        self.consumer = yield self.consume(%0A            'garbage.inbound',%0A            self.consume_user_message,%0A            message_class=TransportUserMessage)%0A%0A    def consume_user_message(self, msg):%0A        self.save_message(%7B%0A            'from': msg%5B'from_addr'%5D,%0A            'to': msg%5B'to_addr'%5D,%0A            'message': msg%5B'content'%5D,%0A            'time': msg%5B'timestamp'%5D,%0A        %7D)%0A

add the garbage_worker file