@cloudamqp/amqp-client
Advanced tools
Readme
AMQP 0-9-1 client both for Node.js and browsers (using WebSocket). API documentation.
This library is Promise-based and hence works very well with async/await. It's secure by default, for instance, publishes aren't fulfilled until either the data has been sent on the wire (so that back propagation is respected), or if the channel has Publish Confirms enabled, it isn't fulfilled until the server has acknowledged that the message has been enqueued.
The library was developed so to make it easy for developers who already are familiar with AMQP to write browser apps that communicates directly with an AMQP server over WebSocket.
The library is developed and supported by CloudAMQP, the largest hosted RabbitMQ provider in the world.
npm install @cloudamqp/amqp-client --save
For web browsers a rolled up version is available in dist/.
Using AMQP in Node.js:
import AMQPClient from '@cloudamqp/amqp-client'
async function run() {
try {
const amqp = new AMQPClient("amqp://localhost")
const conn = await amqp.connect()
const ch = await conn.channel()
const q = await ch.queue()
const consumer = await q.subscribe({noAck: true}, async (msg) => {
console.log(msg.bodyToString())
await consumer.cancel()
})
await q.publish("Hello World", {deliveryMode: 2})
await consumer.wait() // will block until consumer is canceled or throw an error if server closed channel/connection
await conn.close()
} catch (e) {
console.error("ERROR", e)
e.connection.close()
setTimeout(run, 1000) // will try to reconnect in 1s
}
}
run()
Using AMQP over WebSockets in a browser:
<!DOCTYPE html>
<html>
<head>
<script type=module>
import AMQPClient from './js/amqp-websocket-client.mjs'
const textarea = document.getElementById("textarea")
const input = document.getElementById("message")
const tls = window.location.scheme === "https:"
const url = `${tls ? "wss" : "ws"}://${window.location.host}`
const amqp = new AMQPClient(url, "/", "guest", "guest")
async function start() {
try {
const conn = await amqp.connect()
const ch = await conn.channel()
attachPublish(ch)
const q = await ch.queue("")
await q.bind("amq.fanout")
const consumer = await q.subscribe({noAck: false}, (msg) => {
console.log(msg)
textarea.value += msg.bodyToString() + "\n"
msg.ack()
})
} catch (err) {
console.error("Error", err, "reconnecting in 1s")
disablePublish()
setTimeout(start, 1000)
}
}
function attachPublish(ch) {
document.forms[0].onsubmit = async (e) => {
e.preventDefault()
try {
await ch.basicPublish("amq.fanout", "", input.value, { contentType: "text/plain" })
} catch (err) {
console.error("Error", err, "reconnecting in 1s")
disablePublish()
setTimeout(start, 1000)
}
input.value = ""
}
}
function disablePublish() {
document.forms[0].onsubmit = (e) => { alert("Disconnected, waiting to be reconnected") }
}
start()
</script>
</head>
<body>
<form>
<textarea id="textarea" rows=10></textarea>
<br/>
<input id="message"/>
<button type="submit">Send</button>
</form>
</body>
</html>
FAQs
AMQP 0-9-1 client, both for browsers (WebSocket) and node (TCP Socket)
The npm package @cloudamqp/amqp-client receives a total of 21,899 weekly downloads. As such, @cloudamqp/amqp-client popularity was classified as popular.
We found that @cloudamqp/amqp-client demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 3 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
A hospital in Mobile, Alabama, agreed to a settlement in a landmark ransomware death lawsuit, but is now reportedly reconsidering the agreement and refusing to pay.
Security News
A new report explores how advancements in LLMs are enhancing cyber threats, including polymorphic malware, personalized spearphishing, and the risk of hijacking customer service bots.
Security News
ESLint has approved an RFC that adds support for TypeScript configuration files, which is aimed at improving the developer experience and recognizing changes in the evolving JavaScript ecosystem.