pjrpc

pjrpc copied to clipboard

[email protected]: Exception from close() after connect()

3

```py import asyncio from pjrpc.client.backend import aio_pika as pjrpc_client async def main(): client = pjrpc_client.Client('amqp://guest:guest@localhost:5672/v1', 'jsonrpc') await client.connect() await client.close() if __name__ == "__main__": asyncio.run(main()) ``` with 1.6.0, this results...

bernhardkaindl

@dapper91: client and server for JSON-RPC over MQTT with examples RFC: It's dependency library asyncio-paho needs python >= 3.8, updated in pyproject.toml accordingly to >3.8 I understand that not supporting...

bernhardkaindl

examples/aio_pika_*.py: example RPC to schedule a shutdown (e.g. for restart)

1

examples/aio_pika_*.py: Implement shutdown RPC to support restarting the server Add RPC method to terminate the server, useful for restarting it with updated code: Especially useful during development of new code,...

bernhardkaindl

Hello @dapper91, Thank you for merging our last adjustments already. It works just as smooth as expected. While testing, we found an issue with the aio_pika backend. In case a...

jgrasboeck