A publisher subscriber (pub-sub) producer using ActiveMQ Artemis connector for Ballerina

pub_sub_producer.bal

import ballerina/artemis;
import ballerina/log;
import ballerina/io;

public function main() {
    artemis:Producer prod = new({host:"localhost", port:61616}, "my_address", addressConfig = {routingType:artemis:MULTICAST});
    map<string> msg = {"Hello":"World", "some":"world"};
    byte[6] vals = [1,2,2,3,3,2];
    io:ReadableByteChannel ch = io:openReadableFile("/home/riyafa/abc.pdf");
    var err = prod->send(vals);
    err = prod->send(msg);
    err = prod->send(ch);
    if(err is error){
        log:printError("Error occurred sending message", err = err);
    }
    if(!prod.isClosed()) {
        err = prod->close();
        if(err is error){
            log:printError("Error occurred closing producer", err = err);
        }
    }
}