1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# this handler responds to every request with "hello world"
import tnetstring
import zmq
ctx = zmq.Context()
sock = ctx.socket(zmq.REP)
sock.connect("ipc://client")
while True:
m_raw = sock.recv()
req = tnetstring.loads(m_raw[1:])
print("IN {}".format(req))
resp = {}
resp[b"id"] = req[b"id"]
resp[b"code"] = 200
resp[b"reason"] = b"OK"
resp[b"headers"] = [[b"Content-Type", b"text/plain"]]
resp[b"body"] = b"hello world\n"
print("OUT {}".format(resp))
sock.send(b"T" + tnetstring.dumps(resp))
|
