neomedsys / mrsal Goto Github PK

After tests are written, then make a CI/CD pipeline for auto release and publish

We need to make the start_consumer continuous, which can be done by a while loop. We have to let the user keyboard interrupt as well.

We need to be able to manually acknowledge a message by creating a method can be called upon to do so. The current situation is not ideal as the ack only happens after the callback returns true. The consumption should NOT handle the ack rather the callback should always handle the ack as it sees itself fit.

It appears that numerous unnecessary messages from tests have been published to the Mrsal exchanges. We should take steps to clean up and remove these messages.

Connection info:

host=rabbitmq.neomodels.app,
virtual_host=myMrsalHost,
port=5671,
heartbeat=18000,
ssl=True

Can we rewrite this in order to have it more compact. One approach could be to asterix operator to unpack args --> *args * total_threads

• Investigate & use nox.
• Add new test with SSL/TLS connection.

The basic props of Pika should be handled by Mrsal with default values that can be changed by the user.

Rewrite the tests to fit the changes from #8 and make them more testable as in decoupling the current ones .