summaryrefslogtreecommitdiff
path: root/rpc/relay.py
diff options
context:
space:
mode:
Diffstat (limited to 'rpc/relay.py')
-rw-r--r--rpc/relay.py14
1 files changed, 7 insertions, 7 deletions
diff --git a/rpc/relay.py b/rpc/relay.py
index 9e56001..57670d5 100644
--- a/rpc/relay.py
+++ b/rpc/relay.py
@@ -7,19 +7,19 @@ load_dotenv(find_dotenv())
class RelayRPC(object):
def start(self):
- print("Relay running on port {}".format(os.getenv('RELAY_PORT')))
+ print('Relay running on port {}'.format(os.getenv('RELAY_PORT')))
def connected(self, msg):
- print("got connect, trying to call back.")
- print("Connecting to RPC on port {}".format(os.getenv('RPC_PORT')))
+ print('got connect, trying to call back.')
+ print('Connecting to RPC on port {}'.format(os.getenv('RPC_PORT')))
client = zerorpc.Client()
- client.connect("tcp://127.0.0.1:" + os.getenv('RPC_PORT'))
- client.send_param("key", "value")
+ client.connect('tcp://127.0.0.1:' + os.getenv('RPC_PORT'))
+ client.send_param('key', 'value')
def send_frame(self, frame):
- print("got frame: {} bytes".format(len(frame)))
+ print('got frame: {} bytes'.format(len(frame)))
rpc = RelayRPC()
server = zerorpc.Server(rpc)
-server.bind("tcp://127.0.0.1:" + os.getenv('RELAY_PORT'))
+server.bind('tcp://127.0.0.1:' + os.getenv('RELAY_PORT'))
server.run()