I have a question about stream. plz help me

[garamssi]

const amqp = require('amqplib');

async function sendMsg() {
    try {
        // RabbitMQ
        const connection = await amqp.connect({
            hostname: 
            port: 
            username: 
            password: 
        });

        const channel = await connection.createChannel();

        const queue = 'example_stream';

        await channel.assertQueue(queue, {
            arguments: { 'x-queue-type': 'stream' }
        });

        const msg = 'Hello World';
        channel.sendToQueue(queue, Buffer.from(msg));
        console.log(` [x] Sent ${msg}`)

        // consume....

    } catch (error) {
        console.error('Error:', error);
    }
}

const rabbit = require("rabbitmq-stream-js-client");

async function main() {
    const streamName = "hello-nodejs-stream";

    console.log("Connecting...");
    const client = await rabbit.connect({
        vhost: "/",
        port: 5552,
        hostname: "localhost",
        username: "guest",
        password: "guest",
    });

    console.log("Making sure the stream exists...");
    const streamSizeRetention = 5 * 1e9
    await client.createStream({ stream: streamName, arguments: { "max-length-bytes": streamSizeRetention } });

    console.log("Creating the publisher...");
    const publisher = await client.declarePublisher({ stream: streamName });

    console.log("Sending a message...");
    await publisher.send(Buffer.from("Test message"));

    console.log("Closing the connection...");
    await client.close();
}

main()
    .then(() => console.log("done!"))
    .catch((res) => {
        console.log("Error in publishing message!", res);
        process.exit(-1);
    });

I'm not sure which of the two code examples above is the correct approach for streaming. Could you please explain? What are the differences between them?

[acogoluegnes]

It is possible to interact with RabbitMQ streams with the protocols that RabbitMQ supports. The preferred protocol is the stream protocol, because it is optimized for streams and all features are available with it. The second example in your question uses the stream protocol. The first example uses the AMQP 091 protocol.

You should use the stream protocol if you don't have restrictions on the protocol or the client library in your system.

See also this comparison page.

[garamssi]

Thank you, acogoluegnes, for your response. It was extremely helpful, and the reference site provided exactly the information I was looking for. Thanks again.