first example

Author: apietroni51

examples/index.js

@@ -1 +1,35 @@
-const rabbit = require("rabbitmq-amqp-js-client")
+const rabbit = require("rabbitmq-amqp-js-client")
+
+const queueName = "test-queue"
+
+async function main() {
+    const environment = rabbit.createEnvironment({
+        host: "localhost",
+        port: 5672,
+        username: "rabbit",
+        password: "rabbit",
+    })
+    
+    const connection = await environment.createConnection()
+
+    connection.management().declareQueue(queueName)
+
+    connection.createConsumer(queueName, { messageHandler: (message) => {
+        console.log("received message", message.body)
+    }})
+
+    const publisher = await connection.createPublisher({ queue: { name: queueName } })
+    publisher.publish({ body: "message body"})
+
+    await sleep(2000)
+
+    await environment.close()
+}
+
+main()
+  .then(() => console.log("done!"))
+  .catch((res) => {
+    console.log("ERROR ", res)
+    process.exit(-1)
+  })
+const sleep = (ms) => new Promise((r) => setTimeout(r, ms))

src/index.ts

@@ -1,5 +1,5 @@
 export { Management, AmqpManagement } from "./management.js"
-export { Environment, AmqpEnvironment } from "./environment.js"
+export { Environment, AmqpEnvironment, createEnvironment } from "./environment.js"
 export { Connection, AmqpConnection } from "./connection.js"
 export { Publisher, AmqpPublisher } from "./publisher.js"
 export { Consumer, AmqpConsumer } from "./consumer.js"