Producer

import ballerina/io;
import ballerina/rabbitmq;

public function main() {
    // Creates a ballerina RabbitMQ connection that allows re-usability if necessary.
    rabbitmq:Connection connection = new ({host: "localhost", port: 5672});

    // Creates multiple ballerina RabbitMQ channels.
    rabbitmq:Channel newChannel1 = new (connection);
    rabbitmq:Channel newChannel2 = new (connection);

    // Declares the queue, MyQueue1.
    var queueResult1 = newChannel1->queueDeclare({queueName: "MyQueue1"});
    if (queueResult1 is error) {
        io:println("An error occurred while creating the MyQueue1 queue.");
    }

    // Declares the queue, MyQueue2.
    var queueResult2 = newChannel2->queueDeclare({queueName: "MyQueue2"});
    if (queueResult2 is error) {
        io:println("An error occurred while creating the MyQueue2 queue.");
    }

    // Publishing messages to an exchange using a routing key.
    // Publishes the message using newChannel1 and the routing key named MyQueue1.
    worker w1 {
        var sendResult = newChannel1->basicPublish("Hello from Ballerina",
                                        "MyQueue1");
        if (sendResult is error) {
            io:println("An error occurred while sending the message to " +
                     "MyQueue1 using newChannel1.");
        }
    }

    // Publishing messages to the same routing key using a different channel.
    // Publishes the message using newChannel2 and the same routing key named MyQueue1.
    worker w2 {
        var sendResult = newChannel2->basicPublish("Hello from Ballerina",
                                        "MyQueue1");
        if (sendResult is error) {
            io:println("An error occurred while sending the message to " +
                    "MyQueue1 using newChannel2.");
        }
    }

    // Publishing messages to different routing keys using the same channel.
    // Publishes the message using newChannel1 to a different routing key named MyQueue2.
    worker w3 {
        var sendResult = newChannel1->basicPublish("Hello from Ballerina",
                                        "MyQueue2");
        if (sendResult is error) {
            io:println("An error occurred while sending the message to " +
                    "MyQueue2 using newChannel1.");
        }
    }
    _ = wait {w1, w2, w3};
}

Producer

In this example, messages are sent to two different queues, to one queue using the same channel and to the other using two different channels.

< PREVIOUS

SASL Authentication - Producer

NEXT >

Consumer

import ballerina/io;
import ballerina/rabbitmq;

public function main() {

    rabbitmq:Connection connection = new ({host: "localhost", port: 5672});

Creates a ballerina RabbitMQ connection that allows re-usability if necessary.

    rabbitmq:Channel newChannel1 = new (connection);
    rabbitmq:Channel newChannel2 = new (connection);

Creates multiple ballerina RabbitMQ channels.

    var queueResult1 = newChannel1->queueDeclare({queueName: "MyQueue1"});
    if (queueResult1 is error) {
        io:println("An error occurred while creating the MyQueue1 queue.");
    }

Declares the queue, MyQueue1.

    var queueResult2 = newChannel2->queueDeclare({queueName: "MyQueue2"});
    if (queueResult2 is error) {
        io:println("An error occurred while creating the MyQueue2 queue.");
    }

Declares the queue, MyQueue2.

    worker w1 {
        var sendResult = newChannel1->basicPublish("Hello from Ballerina",
                                        "MyQueue1");
        if (sendResult is error) {
            io:println("An error occurred while sending the message to " +
                     "MyQueue1 using newChannel1.");
        }
    }

Publishing messages to an exchange using a routing key. Publishes the message using newChannel1 and the routing key named MyQueue1.

    worker w2 {
        var sendResult = newChannel2->basicPublish("Hello from Ballerina",
                                        "MyQueue1");
        if (sendResult is error) {
            io:println("An error occurred while sending the message to " +
                    "MyQueue1 using newChannel2.");
        }
    }

Publishing messages to the same routing key using a different channel. Publishes the message using newChannel2 and the same routing key named MyQueue1.

    worker w3 {
        var sendResult = newChannel1->basicPublish("Hello from Ballerina",
                                        "MyQueue2");
        if (sendResult is error) {
            io:println("An error occurred while sending the message to " +
                    "MyQueue2 using newChannel1.");
        }
    }
    _ = wait {w1, w2, w3};
}

Publishing messages to different routing keys using the same channel. Publishes the message using newChannel1 to a different routing key named MyQueue2.

# Make sure to have the RabbitMQ broker running.
#
# Navigate to the directory that contains the
# 'rabbitmq_producer.bal' file, and issue the 'ballerina run' command as follows.

ballerina run rabbitmq_producer.bal

Producer

Cookie policy