diff options
author | Jeff Garzik <jgarzik@bitpay.com> | 2015-09-16 09:12:07 -0400 |
---|---|---|
committer | Jeff Garzik <jgarzik@bitpay.com> | 2015-09-16 09:12:07 -0400 |
commit | 13b828270a6f912aeb24dee87108c6bda83d1b96 (patch) | |
tree | 1c39d082db96075c308b470852e761086ff8fc65 /contrib | |
parent | 9733bc99a0b967522ff47e00f4d8e408e6ee5c4f (diff) | |
parent | 029e278286cb861901c9cb8e1b84855ec1640aac (diff) | |
download | bitcoin-13b828270a6f912aeb24dee87108c6bda83d1b96.tar.xz |
Merge pull request #6103
Diffstat (limited to 'contrib')
-rwxr-xr-x | contrib/zmq/zmq_sub.py | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/contrib/zmq/zmq_sub.py b/contrib/zmq/zmq_sub.py new file mode 100755 index 0000000000..decf29d42a --- /dev/null +++ b/contrib/zmq/zmq_sub.py @@ -0,0 +1,37 @@ +#!/usr/bin/env python2 + +import array +import binascii +import zmq + +port = 28332 + +zmqContext = zmq.Context() +zmqSubSocket = zmqContext.socket(zmq.SUB) +zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashblock") +zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashtx") +zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawblock") +zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawtx") +zmqSubSocket.connect("tcp://127.0.0.1:%i" % port) + +try: + while True: + msg = zmqSubSocket.recv_multipart() + topic = str(msg[0]) + body = msg[1] + + if topic == "hashblock": + print "- HASH BLOCK -" + print binascii.hexlify(body) + elif topic == "hashtx": + print '- HASH TX -' + print binascii.hexlify(body) + elif topic == "rawblock": + print "- RAW BLOCK HEADER -" + print binascii.hexlify(body[:80]) + elif topic == "rawtx": + print '- RAW TX -' + print binascii.hexlify(body) + +except KeyboardInterrupt: + zmqContext.destroy() |