GPMQ

General Purpose Message Queue — A lightweight Python distributed message queue built on Redis Streams, designed for personal projects.

Beta release of version-0.4.0

Features

Multiple messaging patterns — sync, async, fire-and-forget, batch with sliding-window concurrency, and message relay
Targeted publishing — direct a message to specific subscriber(s) via target_subscribers; registered-but-unlisted subscribers discard it
Configurable run-forever method — customize the subscriber's main loop with @run_forever_method
Redis Streams backend — reliable message delivery with consumer groups
Multi-process workers — configurable worker count per subscriber
YAML configuration — type-safe config via gpconfig with common/specific merging
Audit trail — optional SQLite-based message and result logging
Worker visibility — query all workers in a consumer group including idle/stale ones via get_consumer_group_workers()
CLI tools — start workers, query audit records, check system status