9 zmqContext
= zmq
.Context()
10 zmqSubSocket
= zmqContext
.socket(zmq
.SUB
)
11 zmqSubSocket
.setsockopt(zmq
.SUBSCRIBE
, "hashblock")
12 zmqSubSocket
.setsockopt(zmq
.SUBSCRIBE
, "hashtx")
13 zmqSubSocket
.setsockopt(zmq
.SUBSCRIBE
, "rawblock")
14 zmqSubSocket
.setsockopt(zmq
.SUBSCRIBE
, "rawtx")
15 zmqSubSocket
.connect("tcp://127.0.0.1:%i" % port
)
19 msg
= zmqSubSocket
.recv_multipart()
23 if topic
== "hashblock":
24 print "- HASH BLOCK -"
25 print binascii
.hexlify(body
)
26 elif topic
== "hashtx":
28 print binascii
.hexlify(body
)
29 elif topic
== "rawblock":
30 print "- RAW BLOCK HEADER -"
31 print binascii
.hexlify(body
[:80])
32 elif topic
== "rawtx":
34 print binascii
.hexlify(body
)
36 except KeyboardInterrupt: