import ballerina/mb;
import ballerina/log;endpoint mb:SimpleDurableTopicSubscriber subscriber {
    topicPattern: "BallerinaTopic",
    identifier: "sub-1"
};service<mb:Consumer> jmsListener bind subscriber {    onMessage(endpoint consumer, mb:Message message) {
        string messageText = check message.getTextMessageContent();
        log:printInfo("Message : " + messageText);
    }
}

MB Simple Durable Topic Message Subscriber

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

import ballerina/mb;
import ballerina/log;
endpoint mb:SimpleDurableTopicSubscriber subscriber {
    topicPattern: "BallerinaTopic",
    identifier: "sub-1"
};
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-durable-topic-message-subscriber.bal

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