Metadata-Version: 2.4
Name: redqlite
Version: 1.0.0
Summary: A lightweight Messaging queue implementation using Redis for producer-worker-subscriber messaging.
Author: Shashank Gandhi
License-Expression: MIT
Project-URL: Homepage, https://github.com/shashankgandhi1/redqlite
Project-URL: Bug Tracker, https://github.com/shashankgandhi1/redqlite/issues
Classifier: Programming Language :: Python :: 3
Classifier: Operating System :: OS Independent
Requires-Python: >=3.12
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: redis==6.2.0
Dynamic: license-file

# RedQLite

A lightweight Messaging queue implementation using Redis for producer-worker messaging.

---

## Features

- Redis-backed message queuing
- Producer and worker interface
- Lightweight and fast alternative to Kafka
- Works for long running tasks
- Provides configurable heartbeats from inside worker callback functions
- Redis server required
- Minimal setup — no Kafka or Zookeeper required

---

## Installation

```bash
pip install redqlite
```

## How It Works
This package simulates a basic Kafka-style messaging system using Redis lists.
It includes:

A **Producer** that pushes messages to a Redis queue or broadcasts messages to all subscribers.

A **Worker** that consumes messages from the queue and processes them.

A **Worker Pool** to run concurrent workers. 

A **Subscriber** that consumes messages from channel specific message queue.

## Usage
### Example: Producing a Message
```python
# Import RQProducer class
from redqlite.producer import RQProducer

# Create a producer instance (assumes redis running on localhost:6379)
rqproducer = RQProducer()

# Send a message
rqproducer.send(topic="your_topic_name", message="hello world")

# Broadcast message on a channel
rqproducer.broadcast(channel="your_channel_name", message="hello world")
```

### Example: Starting a Worker
```python
# Import QWorker class
from redqlite.worker import RQWorker

def callback_func(msg, **kwargs):
	print(msg)

# Create a worker instance (assumes redis running on localhost:6379)
rqworker = RQWorker(topic="your_topic_name", callback=callback_func)

# Start worker thread
rqworker.start()

```

### Example: Starting a subscriber
```python
# Import QSubscriber class
from redqlite.subscriber import RQSubscriber

def callback_func(msg, **kwargs):
	print(msg)

# Create a worker instance (assumes redis running on localhost:6379)
rqsubscriber = RQSubscriber(channel="your_channel_name", callback=callback_func)

# Start subscriber thread
rqsubscriber.start()

```

## License
This project is licensed under the MIT License - see the [LICENSE](LICENSE) file for details.

## Contributing
Pull requests are welcome. For major changes, please open an issue first to discuss what you’d like to change.

## Contact
Created by **Shashank Gandhi** – feel free to reach out by [opening an issue](https://github.com/shashankgandhi1/redqlite/issues) or by [contacting the author](https://github.com/shashankgandhi1).


