Skip to content

Commit

Permalink
moved from IPv6 to IPv4
Browse files Browse the repository at this point in the history
  • Loading branch information
sorousherafat committed Feb 13, 2024
1 parent 6e26c32 commit 7e590d9
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ def DropReplicaMessages(self, request, context):
server = grpc.server(ThreadPoolExecutor(max_workers=10))
broker = BrokerServer()
broker_pb2_grpc.add_BrokerServicer_to_server(broker, server)
server.add_insecure_port(f'[::]:{os.environ["BROKER_PORT"]}')
server.add_insecure_port(f'0.0.0.0:{os.environ["BROKER_PORT"]}')
server.start()
channel = grpc.insecure_channel(f'{os.environ["ZOOKEEPER_HOST"]}:{os.environ["ZOOKEEPER_PORT"]}')
stub = proto.zookeeper_pb2_grpc.ZookeeperStub(channel)
Expand Down
2 changes: 1 addition & 1 deletion zookeeper/zookeeper.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,6 @@ def Register(self, request, context):
manager = BrokerManager()
message_pb2_grpc.add_MessageQueueServicer_to_server(MessageQueue(manager), server)
zookeeper_pb2_grpc.add_ZookeeperServicer_to_server(Zookeeper(manager), server)
server.add_insecure_port(f"[::]:{os.getenv('ZOOKEEPER_PORT')}")
server.add_insecure_port(f"0.0.0.0:{os.getenv('ZOOKEEPER_PORT')}")
server.start()
server.wait_for_termination()

0 comments on commit 7e590d9

Please sign in to comment.