Skip to content

daa/filemq

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 

Repository files navigation

This python module provides file-based message queue.

example of use:

import filemq
# new message queue in /var/spool/filemq
mq = filemq.FileMQ('/var/spool/filemq')
# put message to queue
mq.put('hello')
# get message
m = mq.get()
# now work with it
# ...
# commit if message successfully worked
mq.commit(m)
# or you may put message back to queue:
# mq.rollback(m)
# or remove from queue signalling that message processing
# was unsuccessful
# mq.discard(m)

About

file-based message queue for python

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages