initial

Author: JensWalter

.gitignore

@@ -8,3 +8,12 @@ Cargo.lock
 
 # These are backup files generated by rustfmt
 **/*.rs.bk
+
+
+# Added by cargo
+#
+# already existing elements were commented out
+
+/target
+#Cargo.lock
+/deps

Cargo.toml

@@ -0,0 +1,14 @@
+[package]
+name = "tibco_ems-sys"
+version = "0.0.1"
+authors = ["Jens Walter <[email protected]>"]
+edition = "2018"
+license = "Apache-2.0"
+keywords = ["tibco","ems"]
+repository = "https://github.com/apimeister/tibco-ems-sys-rs/"
+description = "Rust bindings for the Tibco EMS C library."
+
+[lib]
+name = "tibco_ems_sys"
+
+[dependencies]

README.md

@@ -1 +1,80 @@
-# tibco-ems-sys-rs
+# tibco_ems-sys
+[![Latest Version](https://img.shields.io/crates/v/tibco_ems-sys.svg)](https://crates.io/crates/tibco_ems-sys)
+
+Rust bindings for the Tibco EMS C library.
+
+A high-level API is provided through the `tibco_ems` crate.
+
+[![Latest Version](https://img.shields.io/crates/v/tibco_ems.svg)](https://crates.io/crates/tibco_ems)
+
+
+# License
+tibco_ems is licensed under Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0).
+
+TIBCO Enterprise Messaging Service, and all related components therein are property of TIBCO Software, and are not provided with this software package. Refer to your own TIBCO License terms for details.
+
+# Build
+
+To build this crate, the TIBCO EMS C library must either be in the LD_LIBRARY_PATH or alternatively a EMS_HOME environment variable must be set.
+
+## Usage
+
+Put this in your `Cargo.toml`:
+
+```text
+[dependencies]
+tibco_ems-sys = "0.1"
+```
+
+## Examples
+
+Sending a text message to a queue.
+
+```rust
+use tibco_ems::c_binding::*;
+use std::ffi::CString;
+
+fn main() {
+  unsafe{
+    let factory = tibemsConnectionFactory_Create();
+
+    let url = "tcp://localhost:7222";
+    let user="admin";
+    let password="admin";
+
+    let status = tibemsConnectionFactory_SetServerURL(factory, CString::new(url).unwrap().as_ptr());
+    println!("tibemsConnectionFactory_SetServerURL: {:?}",status);
+
+    let mut conn: usize = 0;
+    let status = tibemsConnectionFactory_CreateConnection(factory,&mut conn,CString::new(user).unwrap().as_ptr(),CString::new(password).unwrap().as_ptr());
+    println!("tibemsConnectionFactory_CreateConnection: {:?}",status);
+
+    let mut sess: usize = 0;
+    let status = tibemsConnection_CreateSession(conn,&mut sess,tibems_bool::TIBEMS_FALSE,tibemsAcknowledgeMode::TIBEMS_AUTO_ACKNOWLEDGE);
+    println!("tibemsConnection_CreateSession: {:?}",status);
+
+    let dest_str = "myqueue";
+    let mut dest: usize = 0;
+    let status = tibemsDestination_Create(&mut dest, tibemsDestinationType::TIBEMS_QUEUE, CString::new(dest_str).unwrap().as_ptr());
+    println!("tibemsDestination_Create: {:?}",status);
+
+    let mut producer: usize = 0;
+    let status = tibemsSession_CreateProducer(sess,&mut producer,dest);
+    println!("tibemsSession_CreateProducer: {:?}",status);
+
+    let mut msg: usize = 0;
+    let status = tibemsTextMsg_Create(&mut msg);
+    println!("tibemsTextMsg_Create: {:?}",status);
+
+    let content="hallo welt";
+    let status = tibemsTextMsg_SetText(msg,CString::new(content).unwrap().as_ptr());
+    println!("tibemsTextMsg_SetText: {:?}",status);
+
+    let status = tibemsMsg_SetStringProperty(msg,CString::new("key").unwrap().as_ptr(),CString::new("val").unwrap().as_ptr());
+    println!("tibemsMsg_SetStringProperty: {:?}",status);
+
+    let status = tibemsMsgProducer_Send(producer, msg);
+    println!("tibemsMsgProducer_Send: {:?}",status);
+  }
+}
+```

build.rs

@@ -0,0 +1,14 @@
+
+fn main() {
+  match std::env::var("EMS_HOME") {
+    Ok(directory) => {
+      println!("cargo:rustc-link-search=native={}", directory);
+      println!("cargo:rustc-link-search=native={}/lib", directory);
+      println!("cargo:rustc-link-search=native={}/lib/64", directory);
+    },
+    Err(_err) => {}
+  }
+  println!("cargo:rerun-if-env-changed=EMS_HOME");
+  println!("cargo:rustc-link-lib=dylib=tibems64");
+  println!("cargo:rustc-link-lib=dylib=tibemsadmin64");
+}

examples/send_text_message.rs

@@ -0,0 +1,46 @@
+use tibco_ems_sys::*;
+use std::ffi::CString;
+
+fn main() {
+  unsafe{
+    let factory = tibemsConnectionFactory_Create();
+
+    let url = "tcp://localhost:7222";
+    let user="admin";
+    let password="admin";
+
+    let status = tibemsConnectionFactory_SetServerURL(factory, CString::new(url).unwrap().as_ptr());
+    println!("tibemsConnectionFactory_SetServerURL: {:?}",status);
+
+    let mut conn: usize = 0;
+    let status = tibemsConnectionFactory_CreateConnection(factory,&mut conn,CString::new(user).unwrap().as_ptr(),CString::new(password).unwrap().as_ptr());
+    println!("tibemsConnectionFactory_CreateConnection: {:?}",status);
+
+    let mut sess: usize = 0;
+    let status = tibemsConnection_CreateSession(conn,&mut sess,tibems_bool::TIBEMS_FALSE,tibemsAcknowledgeMode::TIBEMS_AUTO_ACKNOWLEDGE);
+    println!("tibemsConnection_CreateSession: {:?}",status);
+
+    let dest_str = "myqueue";
+    let mut dest: usize = 0;
+    let status = tibemsDestination_Create(&mut dest, tibemsDestinationType::TIBEMS_QUEUE, CString::new(dest_str).unwrap().as_ptr());
+    println!("tibemsDestination_Create: {:?}",status);
+
+    let mut producer: usize = 0;
+    let status = tibemsSession_CreateProducer(sess,&mut producer,dest);
+    println!("tibemsSession_CreateProducer: {:?}",status);
+
+    let mut msg: usize = 0;
+    let status = tibemsTextMsg_Create(&mut msg);
+    println!("tibemsTextMsg_Create: {:?}",status);
+
+    let content="hallo welt";
+    let status = tibemsTextMsg_SetText(msg,CString::new(content).unwrap().as_ptr());
+    println!("tibemsTextMsg_SetText: {:?}",status);
+
+    let status = tibemsMsg_SetStringProperty(msg,CString::new("key").unwrap().as_ptr(),CString::new("val").unwrap().as_ptr());
+    println!("tibemsMsg_SetStringProperty: {:?}",status);
+
+    let status = tibemsMsgProducer_Send(producer, msg);
+    println!("tibemsMsgProducer_Send: {:?}",status);
+  }
+}