import ballerina/mb;
import ballerina/log;endpoint mb:SimpleQueueReceiver listener {
    host: "localhost",
    port: 5672,
    queueName: "MyQueue"
};service<mb:Consumer> jmsListener bind listener {    onMessage(endpoint consumer, mb:Message message) {
        string messageText = check message.getTextMessageContent();
        log:printInfo("Message : " + messageText);
    }
}

MB Simple Queue Message Receiver

This example shows you how to consume a message from Ballerina Message Broker.

import ballerina/mb;
import ballerina/log;
endpoint mb:SimpleQueueReceiver listener {
    host: "localhost",
    port: 5672,
    queueName: "MyQueue"
};
service<mb:Consumer> jmsListener bind listener {
    onMessage(endpoint consumer, mb:Message message) {
        string messageText = check message.getTextMessageContent();
        log:printInfo("Message : " + messageText);
    }
}
$ ballerina run mb-simple-queue-message-consumer.bal

To run the program, put the code in mb-simple-queue-message-consumer.bal and use $BALLERINA_HOME/bin/ballerina.