amqp_worker 0.9.0

AMQP Worker to listen and provide trait to process message
Documentation 
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

use crate::MessageEvent;
use semver::Version;

#[derive(Debug, Serialize, Deserialize)]
pub enum ParameterType {
  #[serde(rename = "array_of_strings")]
  ArrayOfStrings,
  #[serde(rename = "boolean")]
  Boolean,
  #[serde(rename = "credential")]
  Credential,
  #[serde(rename = "integer")]
  Integer,
  #[serde(rename = "requirement")]
  Requirement,
  #[serde(rename = "string")]
  String,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct Parameter {
  pub identifier: String,
  pub label: String,
  pub kind: Vec<ParameterType>,
  pub required: bool,
  // default: DefaultParameterType,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct WorkerConfiguration {
  queue_name: String,
  label: String,
  short_description: String,
  description: String,
  version: Version,
  parameters: Vec<Parameter>,
}

impl WorkerConfiguration {
  pub fn new<ME: MessageEvent>(queue_name: &str, message_event: &'static ME) -> Self {
    WorkerConfiguration {
      queue_name: queue_name.to_string(),
      label: message_event.get_name(),
      version: message_event.get_version(),
      short_description: message_event.get_short_description(),
      description: message_event.get_description(),
      parameters: message_event.get_parameters(),
    }
  }

  pub fn add_parameter(&mut self, parameter: Parameter) {
    self.parameters.push(parameter);
  }
}