Changeset View

Standalone View

	Show All 9 Lines
	port = 28332			port = 28332

	zmqContext = zmq.Context()			zmqContext = zmq.Context()
	zmqSubSocket = zmqContext.socket(zmq.SUB)			zmqSubSocket = zmqContext.socket(zmq.SUB)
	zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashblock")			zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashblock")
	zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashtx")			zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashtx")
	zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawblock")			zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawblock")
	zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawtx")			zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawtx")
	zmqSubSocket.connect("tcp://127.0.0.1:%i" % port)			zmqSubSocket.connect("tcp://127.0.0.1:{}".format(port))

	try:			try:
	while True:			while True:
	msg = zmqSubSocket.recv_multipart()			msg = zmqSubSocket.recv_multipart()
	topic = str(msg[0])			topic = str(msg[0])
	body = msg[1]			body = msg[1]
	sequence = "Unknown"			sequence = "Unknown"
	if len(msg[-1]) == 4:			if len(msg[-1]) == 4:
	Show All 17 Lines