← Back to branch summary

~tr3buchet/nova/lock

« back to all changes in this revision

Viewing changes to nova/fakerabbit.py

  • Committer: Vishvananda Ishaya
  • Date: 2010-12-22 20:59:53 UTC
  • mto: This revision was merged to the branch mainline in revision 482.
  • Revision ID: vishvananda@gmail.com-20101222205953-j2j5t0qjwlcd0t2s
merge trunk and upgrade to cheetah templating

Show diffs side-by-side

added added

removed removed

Lines of Context:
nova/fakerabbit.py
37
37
        self._routes = {}
38
38
 
39
39
    def publish(self, message, routing_key=None):
40
 
        logging.debug('(%s) publish (key: %s) %s',
 
40
        logging.debug(_('(%s) publish (key: %s) %s'),
41
41
                      self.name, routing_key, message)
42
42
        routing_key = routing_key.split('.')[0]
43
43
        if routing_key in self._routes:
44
44
            for f in self._routes[routing_key]:
45
 
                logging.debug('Publishing to route %s', f)
 
45
                logging.debug(_('Publishing to route %s'), f)
46
46
                f(message, routing_key=routing_key)
47
47
 
48
48
    def bind(self, callback, routing_key):
82
82
 
83
83
        def queue_declare(self, queue, **kwargs):
84
84
            if queue not in self._queues:
85
 
                logging.debug('Declaring queue %s', queue)
 
85
                logging.debug(_('Declaring queue %s'), queue)
86
86
                self._queues[queue] = Queue(queue)
87
87
 
88
88
        def exchange_declare(self, exchange, type, *args, **kwargs):
89
89
            if exchange not in self._exchanges:
90
 
                logging.debug('Declaring exchange %s', exchange)
 
90
                logging.debug(_('Declaring exchange %s'), exchange)
91
91
                self._exchanges[exchange] = Exchange(exchange, type)
92
92
 
93
93
        def queue_bind(self, queue, exchange, routing_key, **kwargs):
94
 
            logging.debug('Binding %s to %s with key %s',
 
94
            logging.debug(_('Binding %s to %s with key %s'),
95
95
                          queue, exchange, routing_key)
96
96
            self._exchanges[exchange].bind(self._queues[queue].push,
97
97
                                           routing_key)
117
117
                              content_type=content_type,
118
118
                              content_encoding=content_encoding)
119
119
            message.result = True
120
 
            logging.debug('Getting from %s: %s', queue, message)
 
120
            logging.debug(_('Getting from %s: %s'), queue, message)
121
121
            return message
122
122
 
123
123
        def prepare_message(self, message_data, delivery_mode,