diff options
| author | Soren Hansen <soren.hansen@rackspace.com> | 2010-10-05 15:25:50 +0200 |
|---|---|---|
| committer | Soren Hansen <soren.hansen@rackspace.com> | 2010-10-05 15:25:50 +0200 |
| commit | 5a5da05a966dcdd3113a074468b37e12d406b350 (patch) | |
| tree | 087d4d5304c84f7892f8c6444cd23bd72cd9c87e /nova/fakerabbit.py | |
| parent | 83430481760250e633275182d5cf4eb826f65ea2 (diff) | |
| download | nova-5a5da05a966dcdd3113a074468b37e12d406b350.tar.gz nova-5a5da05a966dcdd3113a074468b37e12d406b350.tar.xz nova-5a5da05a966dcdd3113a074468b37e12d406b350.zip | |
Remove debugging code, and move import to the top.
Diffstat (limited to 'nova/fakerabbit.py')
| -rw-r--r-- | nova/fakerabbit.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/nova/fakerabbit.py b/nova/fakerabbit.py index 6679f8dab..df5e61e6e 100644 --- a/nova/fakerabbit.py +++ b/nova/fakerabbit.py @@ -22,6 +22,7 @@ import logging import Queue as queue from carrot.backends import base +from eventlet import greenthread class Message(base.BaseMessage): @@ -96,12 +97,10 @@ class Backend(object): routing_key) def declare_consumer(self, queue, callback, *args, **kwargs): - print 'declare_consumer', queue, callback self.current_queue = queue self.current_callback = callback def consume(self, *args, **kwargs): - from eventlet import greenthread while True: item = self.get(self.current_queue) if item: |