An idiomatic Elixir client for Nats.io messaging system
Currently PubSub functionality is implemented.
You can start a connection with Natsd like this. See NatsEx.Connection for configuration options.
{:ok, conn} = NatsEx.Connection.connection
For subscription to a certain topic, you can use sub/2
or sub/3
in NatsEx.Connection
module. You can also give a queue group for the subscription.
:ok = NatsEx.Connection.sub(conn, "foo.bar") # No queue group
:ok = NatsEx.Connection.sub(conn, "foo.bar", 22) # Queue group 22
When a new message comes to a certain topic, a new message is received by all the subscribers. The message format is {:nats_ex, :msg, subject, reply_to_subject, payload}
When the connection is down(closed by the server), all the subscribers receive a message {:nats_ex, :conn_down}
For publishing to a certain topic, you can use pub/3
or pub/4
in NatsEx.Connection
module. reply_to
topic is optional.
:ok = NatsEx.Connection.pub(conn, "foo.bar", "This is a payload", "REPLY_SUBJECT")
You can unsubscribe to a certain topic by using unsub/2
or unsub/3
in NatsEx.Connection
module. You can also specify the number of messages, after which the subscriber will be automatically subscribed.
:ok = NatsEx.Connection.unsub(conn, "foo.bar", 10) # 10 is number of messages until unsubscription. This is optional
nats_ex
is available on Hex. For installing, you can do this:
- Add
nats_ex
to your list of dependencies inmix.exs
:
```elixir
def deps do
[{:nats_ex, "~> 0.1"}]
end
```
- Ensure
nats_ex
is started before your application:
```elixir
def application do
[applications: [:nats_ex]]
end
```
- Authorization
- TLS
- Publish, Subscribe
- Request, Reply
- Nats Streaming
MIT License. Please see LICENSE.md for more details.