3_complete_producer.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:MessageProducer queueProducer = check session.createProducer({
        'type: jms:QUEUE,
        name: "test-queue"
    });

    jms:TextMessage message = {
        content: "This is a sample message"
    };
    check queueProducer->send(message);
}