mirror of
https://github.com/oxen-io/oxen-pyoxenmq.git
synced 2023-12-13 20:50:34 +01:00
16 lines
284 B
Python
16 lines
284 B
Python
import pylokimq
|
|
import time
|
|
|
|
def handle_ping(args):
|
|
print(args)
|
|
return args
|
|
|
|
lmq = pylokimq.LokiMQ()
|
|
lmq.listen_plain("ipc:///tmp/lmq.sock")
|
|
lmq.add_anonymous_category("python")
|
|
lmq.add_request_command("python", "ping", handle_ping)
|
|
lmq.start()
|
|
|
|
while True:
|
|
time.sleep(1)
|