kombu/funtests/tests/test_zookeeper.py

11 lines
236 B
Python

from funtests import transport
class test_zookeeper(transport.TransportCase):
transport = "zookeeper"
prefix = "zookeeper"
event_loop_max = 100
def after_connect(self, connection):
connection.channel().client