rabbitmq-stream-js-client

import { connect } from 'rabbitmq-stream-js-client'; import { Buffer } from 'buffer'; // Node.js Buffer is needed for message content async function runRabbitStreamExample() { const client = await connect({ hostname: process.env.RABBITMQ_HOST ?? 'localhost', port: parseInt(process.env.RABBITMQ_STREAM_PORT ?? '5552', 10), username: process.env.RABBITMQ_USERNAME ?? 'rabbit', password: process.env.RABBITMQ_PASSWORD ?? 'rabbit', vhost: process.env.RABBITMQ_VHOST ?? '/', }); const streamName = 'my-first-stream'; // Declare a stream (if it doesn't exist, it will be created) await client.declareStream({ stream: streamName }); const publisher = await client.declarePublisher({ stream: streamName, publisherRef: 'my-publisher-ref', }); const messageContent = Buffer.from('Hello, RabbitMQ Stream!'); await publisher.send(messageContent); console.log('Message published:', messageContent.toString()); const consumer = await client.createConsumer( { stream: streamName, consumerRef: 'my-consumer-ref', offset: 'first', }, (message) => { console.log('Message consumed:', message.getData().toString()); consumer.close(); // Close consumer after first message for this example } ); // Give some time for the consumer to receive the message await new Promise(resolve => setTimeout(resolve, 1000)); await publisher.close(); await client.close(); console.log('Client and publisher closed.'); } runRabbitStreamExample().catch(console.error);