1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108

use std::ffi::CString;
use std::collections::HashMap;

pub mod c_binding;

#[allow(dead_code)]
pub struct Connection{
  pointer: usize
}

#[allow(dead_code)]
#[derive(Debug,Copy,Clone)]
pub struct Session{
  pointer: usize
}

#[allow(dead_code)]
#[derive(Debug,Clone)]
pub struct TextMessage{
  pub body: String,
  pub header: Option<HashMap<String,String>>
}

#[allow(dead_code)]
#[derive(Debug,Clone)]
pub struct Message{
  pub message_type: MessageType,
  body_text: Option<String>,
  body_binary: Option<Vec<u8>>,
}

#[allow(dead_code)]
#[derive(Debug,Clone)]
pub struct Destination{
  pub destination_type: DestinationType,
  pub destination_name: String,
}

#[allow(dead_code)]
#[derive(Debug,Copy,Clone)]
pub enum MessageType{
  TextMessage,
  BytesMessage,
}

#[allow(dead_code)]
#[derive(Debug,Copy,Clone)]
pub enum DestinationType{
  Queue,
  Topic
}
pub fn connect(url: String, user: String, password: String) -> Connection {
  let conn: Connection;
  let mut connection_pointer: usize = 0;
  unsafe{
    let factory = c_binding::tibemsConnectionFactory_Create();
    let status = c_binding::tibemsConnectionFactory_SetServerURL(factory, CString::new(url).unwrap().as_ptr());
    println!("tibemsConnectionFactory_SetServerURL: {:?}",status);
    let status = c_binding::tibemsConnectionFactory_CreateConnection(factory,&mut connection_pointer,CString::new(user).unwrap().as_ptr(),CString::new(password).unwrap().as_ptr());
    println!("tibemsConnectionFactory_CreateConnection: {:?}",status);
    conn = Connection{pointer: connection_pointer};
  }
  conn
}

pub fn session(connection: Connection)-> Session {
  let session: Session;
  unsafe{
    let mut session_pointer:usize = 0;
    let status = c_binding::tibemsConnection_CreateSession(connection.pointer, &mut session_pointer, c_binding::tibems_bool::TIBEMS_FALSE, c_binding::tibemsAcknowledgeMode::TIBEMS_AUTO_ACKNOWLEDGE);
    println!("tibemsConnection_CreateSession: {:?}",status);
    session = Session{pointer: session_pointer};
  }
  session
}

pub fn session_close(session: Session){
  unsafe{
    let status = c_binding::tibemsSession_Close(session.pointer);
    println!("tibemsSession_Close: {:?}",status);
  }
}

pub fn send_text_message(session: Session, destination: Destination, message: TextMessage){
  let mut dest:usize = 0;
  unsafe{
    match destination.destination_type {
      DestinationType::Queue => {
        let status = c_binding::tibemsDestination_Create(&mut dest, c_binding::tibemsDestinationType::TIBEMS_QUEUE, CString::new(destination.destination_name).unwrap().as_ptr());
        println!("tibemsDestination_Create: {:?}",status);
      },
      DestinationType::Topic => {
        let status = c_binding::tibemsDestination_Create(&mut dest, c_binding::tibemsDestinationType::TIBEMS_TOPIC, CString::new(destination.destination_name).unwrap().as_ptr());
        println!("tibemsDestination_Create: {:?}",status);
      }
    }
    let mut producer: usize = 0;
    let status = c_binding::tibemsSession_CreateProducer(session.pointer,&mut producer,dest);
    println!("tibemsSession_CreateProducer: {:?}",status);
    let mut msg: usize = 0;
    let status = c_binding::tibemsTextMsg_Create(&mut msg);
    println!("tibemsTextMsg_Create: {:?}",status);
    let status = c_binding::tibemsTextMsg_SetText(msg,CString::new(message.body).unwrap().as_ptr());
    println!("tibemsTextMsg_SetText: {:?}",status);
    let status = c_binding::tibemsMsgProducer_Send(producer, msg);
    println!("tibemsMsgProducer_Send: {:?}",status);
  }
}