bitninja-ninjarpc 1.1.0

Description:

bitninjaninjarpc 1.1.0

BitNinjaIO NinjaRPC
RabbitMQ rpc server and client by BitNinja.io based on PHP implementation
Usage
The package contains a client, and a server as well, which can communicate with each other.
Server
# import the package
from ninjarpc import Server
from ninjarpc.Encoders import JsonEncoder
from ninjarpc.Routers import SimpleRouter
from ninjarpc.QueueManagers import RabbitMQ

def endpoint_handler(params):
print(f'endpoint was called with {params} parameters.')

if __name__ == '__main__':
queue_manager = RabbitMQ(host='hostname',
port='port',
username='username',
password='password')
encoder = JsonEncoder()
endpoints = {"endpoint": endpoint_handler}
router = SimpleRouter(endpoints)

server = Server('TEST_SERVICE', queue_manager, encoder, router)

while True:
server.listen()

Client
# import the package
from ninjarpc import Client
from ninjarpc.Encoders import JsonEncoder
from ninjarpc.Exceptions import CallTimeoutException
from ninjarpc.QueueManagers import RabbitMQ

if __name__ == '__main__':
queue_manager = RabbitMQ(host='hostname',
port='port',
username='username',
password='password')
encoder = JsonEncoder()
client = Client(queue_manager, encoder)

call = client.async_call(service_name='TEST_SERVICE',
method_name='endpoint',
parameters=())
try:
result = call.wait()
except CallTimeoutException as e:
print('Call timeouted')