mirror of https://github.com/celery/kombu.git
Tests passing
This commit is contained in:
parent
506d9b27c6
commit
3aa889fa57
|
@ -282,9 +282,10 @@ class test_Redis(unittest.TestCase):
|
|||
|
||||
def test_close_poller_not_active(self):
|
||||
c = BrokerConnection(transport=Transport).channel()
|
||||
cycle = c.connection.cycle
|
||||
c.client.connection
|
||||
c.close()
|
||||
self.assertNotIn(c, c.connection.cycle._channels)
|
||||
self.assertNotIn(c, cycle._channels)
|
||||
|
||||
def test_close_ResponseError(self):
|
||||
c = BrokerConnection(transport=Transport).channel()
|
||||
|
|
|
@ -342,9 +342,6 @@ class test_Transport(unittest.TestCase):
|
|||
def setUp(self):
|
||||
self.transport = client().transport
|
||||
|
||||
def test_close_nonexisting_channel(self):
|
||||
self.transport.close_channel("foo")
|
||||
|
||||
def test_close_connection(self):
|
||||
c1 = self.transport.create_channel(self.transport)
|
||||
c2 = self.transport.create_channel(self.transport)
|
||||
|
|
Loading…
Reference in New Issue