Skip to content
Lua Client for AMQP 0.9.1
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
spec
.gitignore
LICENSE
README.md
amqp.lua
bitopers.lua
buffer.lua
consts.lua
frame.lua
logger.lua

README.md

AMQP

Lua Client for AMQP 0.9.1

Requirements

  1. LuaJIT 2.1
  2. busted 2.0 (Testing framework)

Typical Use Cases

  • Consumer
local amqp = require "amqp"
local ctx = amqp.new({role = "consumer", queue = "mengz0", exchange = "amq.topic", ssl = false, user = "guest", password = "guest"})
ctx:connect("127.0.0.1",5672)
local ok, err = ctx:consume()
  • Producer
local amqp = require "amqp"
local ctx = amqp.new({role = "publisher", exchange = "amq.topic", ssl = false, user = "guest", password = "guest"})
ctx:connect("127.0.0.1",5672)
ctx:setup()
local ok, err = ctx:publish("Hello world!")
You can’t perform that action at this time.
You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session.