redis_streams:xidle

Did you know ...

Search Documentation:

Predicate xidle_group/5

HOME
DOWNLOAD
DOCUMENTATION
- Manual
- Packages
- FAQ
- Command line
- PlDoc
- Bluffers▶
- License
- Publications
- Rev 7 Extensions
TUTORIALS
- Beginner▶
- Advanced▶
- Web applications▶
- Semantic web▶
  - ClioPatria
  - RDF namespaces
- Graphics▶
  - XPCE
  - GUI options
- Machine learning▶
  - Probabilistic Logic Programming
- External collections▶
  - Meta level tutorials
- For packagers▶
  - Linux packages
COMMUNITY
COMMERCIAL
WIKI
- Login
- View changes
- Sandbox
- Wiki help
- All tags

xidle_group(+Redis, +Streams, +Starts, +NewStarts, +Options) is det[private]

Called after XREADGROUP returns and the returned messages (if any) have been processed. If Start == NewStarts no messages have been processed, indicating a timeout.

This implementation looks for idle messages on other consumer and will try to claim them.

To be done: - : max time to work on other consumers messages?