camunda_client/apis/
message_api.rs

1/*
2 * Camunda BPM REST API
3 *
4 * OpenApi Spec for Camunda BPM REST API.
5 *
6 * The version of the OpenAPI document: 7.13.0
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11use std::rc::Rc;
12use std::borrow::Borrow;
13#[allow(unused_imports)]
14use std::option::Option;
15
16use reqwest;
17
18use super::{Error, configuration};
19
20pub struct MessageApiClient {
21    configuration: Rc<configuration::Configuration>,
22}
23
24impl MessageApiClient {
25    pub fn new(configuration: Rc<configuration::Configuration>) -> MessageApiClient {
26        MessageApiClient {
27            configuration,
28        }
29    }
30}
31
32pub trait MessageApi {
33    fn deliver_message(&self, correlation_message_dto: Option<crate::models::CorrelationMessageDto>) -> Result<Vec<crate::models::MessageCorrelationResultWithVariableDto>, Error>;
34}
35
36impl MessageApi for MessageApiClient {
37    fn deliver_message(&self, correlation_message_dto: Option<crate::models::CorrelationMessageDto>) -> Result<Vec<crate::models::MessageCorrelationResultWithVariableDto>, Error> {
38        let configuration: &configuration::Configuration = self.configuration.borrow();
39        let client = &configuration.client;
40
41        let uri_str = format!("{}/message", configuration.base_path);
42        let mut req_builder = client.post(uri_str.as_str());
43
44        if let Some(ref user_agent) = configuration.user_agent {
45            req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
46        }
47        req_builder = req_builder.json(&correlation_message_dto);
48
49        // send request
50        let req = req_builder.build()?;
51
52        Ok(client.execute(req)?.error_for_status()?.json()?)
53    }
54
55}
camunda_client/apis/message_api.rs

camunda_client/apis/
message_api.rs
