This repository has been archived on 2024-09-10. You can view files and clone it, but cannot push or open issues or pull requests.

12 lines
308 B
Python

import time
from queue import SimpleQueue
MESSAGE_QUEUE: "SimpleQueue[MessagePayload]" = SimpleQueue()
class MessagePayload(object):
def __init__(self, body: bytes, timestamp: str = ""):
self.request_timestamp = timestamp
self.body = body
self.curretnt_timestamp = time.time()