NioFluxMQ

A thread-safe message queue implementation.

Installation

pip install -U nioflux-mq

uv add -U nioflux-mq

Quick Start

1. Start a server

   python -m nioflux_mq.server
   

   PS D:\project\NioFluxMQ> py -m nioflux_mq.server
   [INFO] 2025-09-01 14:14:35,188 nioflux.mq : \
       _   __ _____                             
      / | / / ____/                             
     /  |/ / /___                               
    / /|  / ____/                               
   /_/ |_/_/                                    
   =0.0.0.0:26105=                              
   NioFluxMQServer started.  
   

2. Access MQ via clients

   1. Connect to a server

      from nioflux_mq.client.client import NioFluxMQClient
      
      client = NioFluxMQClient(host='127.0.0.1', port=26105)
      

   2. Register a topic

      client.register_topic('topic_0')
      

   3. Register a consumer

      client.register_consumer('consumer_0')
      

   4. Sent a message to a topic

      client.produce(b'message_0', 'topic_0', ttl=1)
      

   5. Consume a message

      message = client.consume('consumer_0', 'topic_0').data
      client.advance('consumer_0', 'topic_0')
      

   6. Retreat the pointer if you missread some messages

      client.retreat('consumer_0', 'topic_0')