LUA client for NATS messaging system. https://nats.io
This repository is a fork of the original implementation by dawnangel. It adds optional support for connecting to a NATS server over TLS, and is maintained by PowerDNS.com B.V.
This is a NATS Lua library for Lua 5.1, 5.2 and 5.3. The libraries are copyright by their author 2015 (see the Creators file for details), and released under the MIT license (the same license as Lua itself). There is no warranty.
local nats = require 'nats'
local client = nats.connect({
host = '127.0.0.1',
port = 4222,
})
-- connect to the server
client:connect()
-- callback function for subscriptions
local function subscribe_callback(payload)
print('Received data: ' .. payload)
end
-- subscribe to a subject
local subscribe_id = client:subscribe('foo', subscribe_callback)
-- wait until 2 messages come
client:wait(2)
-- unsubscribe from the subject
client:unsubscribe(subscribe_id)
local nats = require 'nats'
local client = nats.connect({
host = '127.0.0.1',
port = 4222,
})
-- connect to the server
client:connect()
-- publish to a subject
local subscribe_id = client:publish('foo', 'message to be published')
local nats = require 'nats'
local client = nats.connect({
host = '127.0.0.1',
port = 4222,
})
-- user authentication
local user, password = 'user', 'password'
client:set_auth(user, password)
-- connect to the server
client:connect()
local nats = require 'nats'
local client = nats.connect({
host = '127.0.0.1',
port = 4222,
tls = true,
tls_ca_path = '/etc/ssl/certs',
})
-- connect to the server using TLS and validating the server certificate
client:connect()
To install the required libraries you can execute make deps
.
Tests are in the tests
folder.
To run them, you require:
luarocks
andtelescope
installed.- execute
make test
.
Eric Pinto
These libraries are written and maintained by their users. Please make bug report and suggestions on GitHub (see URL at top of file). Pull requests are especially appreciated.