tests working again

This commit is contained in:
Sandy Walsh
2011-02-23 14:41:11 -08:00
parent c2b6060590
commit dd55e66582

View File

@@ -36,7 +36,7 @@ class RpcTestCase(test.TestCase):
super(RpcTestCase, self).setUp() super(RpcTestCase, self).setUp()
self.conn = rpc.Connection.instance(True) self.conn = rpc.Connection.instance(True)
self.receiver = TestReceiver() self.receiver = TestReceiver()
self.consumer = rpc.AdapterConsumer(connection=self.conn, self.consumer = rpc.TopicAdapterConsumer(connection=self.conn,
topic='test', topic='test',
proxy=self.receiver) proxy=self.receiver)
self.consumer.attach_to_eventlet() self.consumer.attach_to_eventlet()
@@ -97,7 +97,7 @@ class RpcTestCase(test.TestCase):
nested = Nested() nested = Nested()
conn = rpc.Connection.instance(True) conn = rpc.Connection.instance(True)
consumer = rpc.AdapterConsumer(connection=conn, consumer = rpc.TopicAdapterConsumer(connection=conn,
topic='nested', topic='nested',
proxy=nested) proxy=nested)
consumer.attach_to_eventlet() consumer.attach_to_eventlet()