Test higher watermark

This commit is contained in:
Ruben van de Ven 2020-02-22 02:02:55 +03:00
parent 7d23e4a478
commit 3832652dc9

View file

@ -216,7 +216,7 @@ class VoiceServer(object):
try: try:
address = "tcp://*:{}".format(self.config['voice']['port'] + self.hugvey.id) address = "tcp://*:{}".format(self.config['voice']['port'] + self.hugvey.id)
self.voice_socket = self.ctx.socket(zmq.PUB) self.voice_socket = self.ctx.socket(zmq.PUB)
self.voice_socket.set_hwm(15) self.voice_socket.set_hwm(25) # not too high, otherwise we flood the network after a short interuption (with stuff that is 'old' anyway)
self.voice_socket.bind(address) self.voice_socket.bind(address)
logger.info( logger.info(