Changeset View
Changeset View
Standalone View
Standalone View
contrib/zmq/zmq_sub.py
Show All 38 Lines | |||||
class ZMQHandler(): | class ZMQHandler(): | ||||
def __init__(self): | def __init__(self): | ||||
self.loop = asyncio.get_event_loop() | self.loop = asyncio.get_event_loop() | ||||
self.zmqContext = zmq.asyncio.Context() | self.zmqContext = zmq.asyncio.Context() | ||||
self.zmqSubSocket = self.zmqContext.socket(zmq.SUB) | self.zmqSubSocket = self.zmqContext.socket(zmq.SUB) | ||||
self.zmqSubSocket.setsockopt(zmq.RCVHWM, 0) | |||||
self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashblock") | self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashblock") | ||||
self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashtx") | self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashtx") | ||||
self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawblock") | self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawblock") | ||||
self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawtx") | self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawtx") | ||||
self.zmqSubSocket.connect(f"tcp://{ip}:{port}") | self.zmqSubSocket.connect(f"tcp://{ip}:{port}") | ||||
async def handle(self): | async def handle(self): | ||||
msg = await self.zmqSubSocket.recv_multipart() | msg = await self.zmqSubSocket.recv_multipart() | ||||
Show All 33 Lines |