Struct FileMessageStoreFactory

Source

pub struct FileMessageStoreFactory(/* private fields */);

Expand description

File based implementation of MessageStore.

Implementations§

Source §

impl FileMessageStoreFactory

Source

pub fn try_new(settings: &SessionSettings) -> Result<Self, QuickFixError>

Try to create new struct from settings.

Examples found in repository ?

examples/fix_getting_started.rs (line 29)

20fn main() -> Result<(), QuickFixError> {
21    let args: Vec<_> = env::args().collect();
22    let Some(config_file) = args.get(1) else {
23        eprintln!("Bad program usage: {} <config_file>", args[0]);
24        exit(1);
25    };
26
27    println!(">> Creating resources");
28    let settings = SessionSettings::try_from_path(config_file)?;
29    let store_factory = FileMessageStoreFactory::try_new(&settings)?;
30    let log_factory = LogFactory::try_new(&StdLogger::Stdout)?;
31    let callbacks = MyApplication;
32    let app = Application::try_new(&callbacks)?;
33
34    let mut acceptor = Acceptor::try_new(
35        &settings,
36        &app,
37        &store_factory,
38        &log_factory,
39        FixSocketServerKind::SingleThreaded,
40    )?;
41
42    println!(">> connection handler START");
43    acceptor.start()?;
44
45    println!(">> App running, press 'q' to quit");
46    let mut stdin = stdin().lock();
47    let mut stdin_buf = [0];
48    loop {
49        let _ = stdin.read_exact(&mut stdin_buf);
50        if stdin_buf[0] == b'q' {
51            break;
52        }
53    }
54
55    println!(">> connection handler STOP");
56    acceptor.stop()?;
57
58    println!(">> All cleared. Bye !");
59    Ok(())
60}

More examples

Hide additional examples

examples/fix_repl/main.rs (line 26)

14fn main() -> Result<(), QuickFixError> {
15    let args: Vec<_> = env::args().collect();
16    let (Some(connect_mode), Some(config_file)) = (args.get(1), args.get(2)) else {
17        eprintln!(
18            "Bad program usage: {} [acceptor|initiator] <config_file>",
19            args[0]
20        );
21        exit(1);
22    };
23
24    println!(">> Creating resources");
25    let settings = SessionSettings::try_from_path(config_file)?;
26    let store_factory = FileMessageStoreFactory::try_new(&settings)?;
27    let log_factory = LogFactory::try_new(&StdLogger::Stdout)?;
28    let callbacks = MyApplication::new();
29    let app = Application::try_new(&callbacks)?;
30
31    match connect_mode.as_str() {
32        "initiator" => server_loop(Initiator::try_new(
33            &settings,
34            &app,
35            &store_factory,
36            &log_factory,
37            FixSocketServerKind::SingleThreaded,
38        )?),
39        "acceptor" => server_loop(Acceptor::try_new(
40            &settings,
41            &app,
42            &store_factory,
43            &log_factory,
44            FixSocketServerKind::SingleThreaded,
45        )?),
46        _ => {
47            eprintln!("Invalid connection mode");
48            exit(1);
49        }
50    }?;
51
52    println!(">> All cleared. Bye !");
53    Ok(())
54}