use tibco_ems::Destination;
use tibco_ems::Message;

fn main() {
    let url = "tcp://localhost:7222";
    let user = "admin";
    let password = "admin";

    let connection = tibco_ems::connect(url, user, password).unwrap();
    let session = connection.session().unwrap();

    let destination = Destination::Topic("mytopic".to_string());

    let consumer = session
        .topic_consumer(&destination, "subscription1", None)
        .unwrap();

    println!("waiting 10 seconds for a message");
    let msg_result = consumer.receive_message(Some(10000));

    match msg_result {
        Ok(result_value) => match result_value {
            Some(message) => match &message {
                Message::TextMessage(text_message) => {
                    println!("received text message");
                    println!("header: {:?}", text_message.header);
                }
                Message::BytesMessage(bytes_message) => {
                    println!("received bytes message");
                    println!("header: {:?}", bytes_message.header);
                }
                Message::ObjectMessage(obj_message) => {
                    println!("received object message");
                    println!("header: {:?}", obj_message.header);
                }
                Message::MapMessage(map_message) => {
                    println!("received map message");
                    println!("header: {:?}", map_message.header);
                }
            },
            None => {
                println!("no message returned");
            }
        },
        Err(status) => {
            println!("returned status: {status:?}");
        }
    }
}