Merge pull request #3028 from PastaPastaPasta/backport-12588

Backport a couple of ZMQ fixes
This commit is contained in:
UdjinM6 2019-07-15 14:39:43 +03:00 committed by Alexander Block
parent 5af6ce91d6
commit 781b165796
2 changed files with 4 additions and 4 deletions

4
contrib/zmq/zmq_sub.py Executable file → Normal file
View File

@ -8,8 +8,8 @@
Dash should be started with the command line arguments: Dash should be started with the command line arguments:
dashd-testnet -daemon \ dashd-testnet -daemon \
-zmqpubhashblock=tcp://127.0.0.1:28332 \
-zmqpubrawtx=tcp://127.0.0.1:28332 \ -zmqpubrawtx=tcp://127.0.0.1:28332 \
-zmqpubrawblock=tcp://127.0.0.1:28332 \
-zmqpubhashtx=tcp://127.0.0.1:28332 \ -zmqpubhashtx=tcp://127.0.0.1:28332 \
-zmqpubhashblock=tcp://127.0.0.1:28332 -zmqpubhashblock=tcp://127.0.0.1:28332
@ -38,7 +38,7 @@ port = 28332
class ZMQHandler(): class ZMQHandler():
def __init__(self): def __init__(self):
self.loop = zmq.asyncio.install() 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)

4
contrib/zmq/zmq_sub3.4.py Executable file → Normal file
View File

@ -8,8 +8,8 @@
Dash should be started with the command line arguments: Dash should be started with the command line arguments:
dashd -testnet -daemon \ dashd -testnet -daemon \
-zmqpubhashblock=tcp://127.0.0.1:28332 \
-zmqpubrawtx=tcp://127.0.0.1:28332 \ -zmqpubrawtx=tcp://127.0.0.1:28332 \
-zmqpubrawblock=tcp://127.0.0.1:28332 \
-zmqpubhashtx=tcp://127.0.0.1:28332 \ -zmqpubhashtx=tcp://127.0.0.1:28332 \
-zmqpubhashblock=tcp://127.0.0.1:28332 -zmqpubhashblock=tcp://127.0.0.1:28332
@ -42,7 +42,7 @@ port = 28332
class ZMQHandler(): class ZMQHandler():
def __init__(self): def __init__(self):
self.loop = zmq.asyncio.install() 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)