3_complete_consumer.bal

import ballerinax/activemq.driver as _;
import ballerinax/java.jms;

public function main() returns error? {
    jms:Connection connection = check new (
        initialContextFactory = "org.apache.activemq.jndi.ActiveMQInitialContextFactory",
        providerUrl = "tcp://localhost:61616"
    );
    jms:Session session = check connection->createSession();

    jms:MessageConsumer consumer = check session.createConsumer(destination = {
        'type: jms:QUEUE,
        name: "test-queue"
    });

    jms:Message? receivedMessage1 = check consumer->receive();
    if receivedMessage1 is jms:TextMessage {
        // do something
    }

    jms:Message? receivedMessage2 = check consumer->receiveNoWait();
    if receivedMessage2 is jms:TextMessage {
        // do something
    }
}