mx-message 3.1.4

A fast, type-safe Rust implementation of MXMessage for parsing MX messages.
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

//! # Dataflow Plugin
//!
//! Dataflow-rs integration for ISO20022 MX message processing.
//! Provides async function handlers for parse, validate, generate, and publish operations.

pub mod common;
pub mod generate;
pub mod parse;
pub mod publish;
pub mod validate;

use dataflow_rs::engine::AsyncFunctionHandler;

// Re-export the main plugin functions
pub use generate::Generate;
pub use parse::Parse;
pub use publish::Publish;
pub use validate::Validate;

/// Register all MX plugin functions for use in dataflow engine
pub fn register_mx_functions() -> Vec<(&'static str, Box<dyn AsyncFunctionHandler + Send + Sync>)> {
    vec![
        ("parse_mx", Box::new(Parse)),
        ("publish_mx", Box::new(Publish)),
        ("validate_mx", Box::new(Validate)),
        ("generate_mx", Box::new(Generate)),
    ]
}