diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-20 14:45:16 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-20 14:45:16 +0200 |
| commit | 83e20713c1c3b55532f6f022eaaf290471d3b5c5 (patch) | |
| tree | 59d23e9052d9ebb2aaec35637b30ead63501a1c6 /python/relay.py | |
| parent | 1a6ae72c46b08c27db0ca5da9fe8f84b38c0f769 (diff) | |
rename rpc
Diffstat (limited to 'python/relay.py')
| -rw-r--r-- | python/relay.py | 25 |
1 files changed, 0 insertions, 25 deletions
diff --git a/python/relay.py b/python/relay.py deleted file mode 100644 index 9e56001..0000000 --- a/python/relay.py +++ /dev/null @@ -1,25 +0,0 @@ -from dotenv import load_dotenv, find_dotenv -import os -import zerorpc -import gevent - -load_dotenv(find_dotenv()) - -class RelayRPC(object): - def start(self): - 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'))) - client = zerorpc.Client() - 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))) - -rpc = RelayRPC() -server = zerorpc.Server(rpc) -server.bind("tcp://127.0.0.1:" + os.getenv('RELAY_PORT')) -server.run() |
