The library implements persistent queue for Elixir applications.
- Add
pers_queueto your deps:
def deps do
[
{:pers_queue, "~> 0.0.1"}
]
end- Add
pers_queueto the list of application dependencies:
def application do
[applications: [:pers_queue]]
endPersQueue 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.setupThis will create the Mnesia schema and message database for you.
# 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
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent