wingfoil 4.0.0

graph based stream processing framework
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

// FIX protocol acceptor example — binds a port and logs incoming FIX messages.
//
// Run with:
//   RUST_LOG=info cargo run --example fix_echo_server --features fix
//
// Then connect a FIX initiator (e.g. the fix_client example) to port 9999.

use log::Level::Info;
use wingfoil::adapters::fix::{FixPollMode, fix_accept};
use wingfoil::*;

fn main() {
    env_logger::init();

    let port = 9999;
    println!("Listening for FIX initiator on port {port}...");

    let (data, status) = fix_accept(port, "SERVER", "CLIENT", FixPollMode::Threaded);

    let data_node = data.logged("fix-data", Info).as_node();
    let status_node = status.logged("fix-status", Info).as_node();

    Graph::new(
        vec![data_node, status_node],
        RunMode::RealTime,
        RunFor::Forever,
    )
    .run()
    .unwrap();
}