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 ReceiverThis 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 |