This commit is contained in:
parent
010e0d708f
commit
844341fdd0
5
test.py
5
test.py
@ -265,10 +265,11 @@ def test_updateconsumer(httpserver):
|
|||||||
currentconsumer=f"127.0.0.1:{port}",
|
currentconsumer=f"127.0.0.1:{port}",
|
||||||
uuid=generateduuid)
|
uuid=generateduuid)
|
||||||
consumerlocator.KNOWNCONSUMER = f"127.0.0.1:{port}"
|
consumerlocator.KNOWNCONSUMER = f"127.0.0.1:{port}"
|
||||||
|
redisconn = redisconnector.RedisConnector()
|
||||||
locator = consumerlocator.ConsumerLocator(
|
locator = consumerlocator.ConsumerLocator(
|
||||||
uuid=generateduuid, communicator=comm,
|
uuid=generateduuid, communicator=comm,
|
||||||
redisconnector=redisconnector.RedisConnector())
|
redisconnector=redisconn)
|
||||||
assert locator.currentconsumer is not None
|
assert redisconn.currentconsumer is not None
|
||||||
ret = locator.updateconsumer()
|
ret = locator.updateconsumer()
|
||||||
assert ret == f"127.0.0.1:{port}"
|
assert ret == f"127.0.0.1:{port}"
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user