Fix message sequencing not being global

This commit is contained in:
Kristóf Tóth 2018-08-01 17:14:56 +02:00
parent 564c97e66a
commit e3b97ee190

View File

@ -65,9 +65,10 @@ class ZMQWebSocketProxy(WebSocketHandler):
LOG.debug('Received on pull socket: %s', message)
self.proxy_eventhandler_to_websocket(message)
def sequence_message(self, message):
self.sequence_number += 1
message['seq'] = self.sequence_number
@classmethod
def sequence_message(cls, message):
cls.sequence_number += 1
message['seq'] = cls.sequence_number
def on_message(self, message):
"""