Redis-backed FIFO message queue implementation.
Use the package manager pip to install Polaris.
pip install git+https://github.com/tandemdude/lightbulb-ext-polaris.git# Receiving messages
import hikari
import lightbulb
import polaris
bot = lightbulb.BotApp(...)
bot.d.polaris = polaris.Consumer("redis://your_redis_server_url")
@bot.d.polaris.handler_for("test_message", polaris.MessageType.CREATE)
async def on_test_message(message: polaris.Message):
print(f"Message received: {message}")
@bot.listen(hikari.StartedEvent)
async def on_started(_):
await bot.d.polaris.run()
@bot.listen(hikari.StoppingEvent)
async def on_stopping(_):
await bot.d.polaris.close()
bot.run()# Sending messages
import polaris
client = polaris.Producer("redis://your_redis_server_url")
msg = polaris.Message(polaris.MessageType.CREATE, "test_message", {"foo": "bar"})
await client.send_message(msg)If you find any bugs, issues, or unexpected behaviour while using the library, you should open an issue with details of the problem and how to reproduce if possible. Please also open an issue for any new features you would like to see added.
Pull requests are welcome. For major changes, please open an issue first to discuss what you would like to change.
Please try to ensure that documentation is updated if you add any features accessible through the public API.
If you use this library and like it, feel free to sign up to GitHub and star the project, it is greatly appreciated and lets me know that I'm going in the right direction!
- Repository: GitHub