summaryrefslogtreecommitdiff
path: root/rpc/relay.py
diff options
context:
space:
mode:
authorjules@lens <julescarbon@gmail.com>2018-05-21 03:02:35 +0200
committerjules@lens <julescarbon@gmail.com>2018-05-21 03:02:35 +0200
commit6bd402bc11a0350479e4d88dc995ab9eb5a75117 (patch)
treee3e44a12d357c201d129cbbcb639bf2224a8aaa1 /rpc/relay.py
parent03566b61318fef6f3ba64334bee7e75f6b7f7c59 (diff)
parente05904f2e992ce3184952a8e569d9c28d85d68de (diff)
blash
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()