import ballerina/mb;
import ballerina/log;endpoint mb:SimpleTopicSubscriber subscriber {
topicPattern: "BallerinaTopic"
};service<mb:Consumer> jmsListener bind subscriber { onMessage(endpoint consumer, mb:Message message) {
string messageText = check message.getTextMessageContent();
log:printInfo("Message : " + messageText);
}
}
MB Simple Topic Message SubscriberThis example shows you how to consume a message from Ballerina Message Broker. |
|
import ballerina/mb;
import ballerina/log;
|
|
endpoint mb:SimpleTopicSubscriber subscriber {
topicPattern: "BallerinaTopic"
};
|
|
service<mb:Consumer> jmsListener bind subscriber {
|
|
onMessage(endpoint consumer, mb:Message message) {
string messageText = check message.getTextMessageContent();
log:printInfo("Message : " + messageText);
}
}
|
|
$ ballerina run mb-simple-topic-message-subscriber.bal
|
To run the program, put the code in |