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]

Duplicate of rabbitmq/rabbitmq-server#11640. Please do not double-post.