Struct transsecs::transsecs_wrapper::TransSecsWrapper

pub struct TransSecsWrapper { /* fields omitted */ }

Wrapper around all TransSecs functions that also contains and manages the JVM

Implementations

impl TransSecsWrapper

pub fn new<'a, S>(classpath: S) -> Result<TransSecsWrapper, Error> where
    S: Into<String>, 

Create a new TransSecsWrapper, using a classpath which must include the runtime jar

pub fn subscribe<'a, S, F>(&self, topic: S, callback: F) -> Result<u128, Error> where
    S: Into<String>,
    F: FnMut(String, ValueObject) + Send + 'static, 

Add a new listener to the broker. Returns the listener uuid which is necessary to unsubscribe, or an error.

pub fn unsubscribe(&self, listener_uuid: u128) -> Result<(), Error>

Unsubscribe from a topic, using the listener_uuid that is returned from a subscription

pub fn start_main<S>(&self, package_name: S) -> Result<(), Error> where
    S: Into<String>, 

Start the main class for the wrapper

pub fn add_test_values_to_broker(&self) -> Result<(), Error>

Add a few test values to the broker

pub fn get<S>(&self, topic: S) -> Result<ValueObject, Error> where
    S: Into<String>, 

Return the latest value associated with a topic. Will return Error::NoSuchTopic if the topic does not exist.

pub fn publish_int<S, I>(&self, topic: S, value: I) -> Result<(), Error> where
    S: Into<String>,
    I: Into<i64>, 

Publish an int to a topic. Will create the topic if it does not exist.

pub fn publish_bool<S, I>(&self, topic: S, value: I) -> Result<(), Error> where
    S: Into<String>,
    I: Into<bool>, 

Publish a bool to a topic. Will create the topic if it does not exist.

pub fn publish_string<S, I>(&self, topic: S, value: I) -> Result<(), Error> where
    S: Into<String>,
    I: Into<String>, 

Publish a string to a topic. Will create the topic if it does not exist.

pub fn publish_json<S, I>(&self, topic: S, value: I) -> Result<(), Error> where
    S: Into<String>,
    I: Into<String>, 

Publish an object in json format to a topic. Will create the topic if it does not exist.

pub fn publish_bytes<S>(&self, topic: S, value: &[u8]) -> Result<(), Error> where
    S: Into<String>, 

Publish a byte slice to a topic. Will create the topic if it does not exist.

pub fn publish_float<S, I>(&self, topic: S, value: I) -> Result<(), Error> where
    S: Into<String>,
    I: Into<f64>, 

Publish a float to a topic. Will create the topic if it does not exist.

pub fn alarm<S>(&self, alarm_name: S, set: bool) -> Result<(), Error> where
    S: Into<String>, 

Set an alarm

pub fn trigger<S>(&self, event_name: S, ceid_trigger: S) -> Result<(), Error> where
    S: Into<String>, 

Trigger an event

Trait Implementations

impl Clone for TransSecsWrapper

fn clone(&self) -> TransSecsWrapper

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.