PersQueue

The library implements persistent queue for Elixir applications.

Installation

1. Add pers_queue to your deps:

def deps do
  [
    {:pers_queue, "~> 0.0.1"}
  ]
end

2. Add pers_queue to the list of application dependencies:

def application do
  [applications: [:pers_queue]]
end

Persistent Setup

PersQueue runs out of the box, but by default all messages are stored in-memory. To persist messages across application restarts, run the following mix task:

$ mix pers_queue.setup

This will create the Mnesia schema and message database for you.

Usage

# Add message:
PersQueue.add("consumer1", "a")  # => :ok
PersQueue.add("consumer1", "b")  # => :ok

# Get message:
PersQueue.get("consumer1")       # => %PersQueue.Message{consumer: "consumer1", content: "a", id: 1}
PersQueue.get("consumer1")       # => %PersQueue.Message{consumer: "consumer1", content: "b", id: 2}

# Ack message by message id:
PersQueue.ack("consumer1", 1)    # => :ok

# Reject message by message id:
PersQueue.reject("consumer1", 2) # => :ok