Struct FixTestVenue 

pub struct FixTestVenue { /* private fields */ }

A local acceptor that plays the counterparty. It persists outbound messages, so it answers resend requests with real retransmissions.

Implementations

impl FixTestVenue

pub fn start( store: &Path, dictionary: &Path, begin_string: &str, venue_comp_id: &str, client_comp_id: &str, ) -> Result<Self, ConnectorError>

Start listening on an ephemeral loopback port as venue_comp_id for a client that logs on as client_comp_id.

Errors

Fails when the engine rejects the settings or cannot listen.

pub fn start_with_settings( store: &Path, dictionary: &Path, begin_string: &str, venue_comp_id: &str, client_comp_id: &str, settings: &[(&'static str, String)], ) -> Result<Self, ConnectorError>

As Self::start, with additional engine settings for the venue.

Errors

Fails when the engine rejects the settings or cannot listen.

pub fn listen( port: u16, store: &Path, dictionary: &Path, begin_string: &str, venue_comp_id: &str, client_comp_id: &str, settings: &[(&'static str, String)], ) -> Result<Self, ConnectorError>

As Self::start_with_settings, listening on port.

Errors

Fails when the engine rejects the settings or cannot listen.

pub fn port(&self) -> u16

Listening port.

pub fn logged_on(&self) -> bool

Whether the client is logged on.

pub fn logons(&self) -> usize

Completed logons so far.

pub fn wait_logged_on(&self, timeout: Duration) -> bool

Wait until the client is logged on, up to timeout.

pub fn send(&self, message: &TestMessage) -> Result<(), ConnectorError>

Send an application message. The engine assigns MsgSeqNum and SendingTime.

Errors

Fails when the message cannot be built or the session is not registered.

pub fn skip_sequence_numbers(&self, count: u64) -> Result<(), ConnectorError>

Skip count outbound sequence numbers, so the client sees a gap and requests a resend that the venue answers with a gap fill.

Errors

Fails when the session is not registered.

pub fn sequence_reset(&self, new_seq: u64) -> Result<(), ConnectorError>

Send SequenceReset-Reset to new_seq and continue numbering from it, skipping messages the client can never recover.

Errors

Fails when the message cannot be sent.

pub fn reset_session(&self) -> Result<(), ConnectorError>

Reset the venue session: Logout, disconnect, and restart both sequence numbers at 1.

Errors

Fails when the session is not registered.

pub fn next_sender(&self) -> Result<u64, ConnectorError>

Next outbound sequence number of the venue.

Errors

Fails when the session is not registered.

pub fn rejects(&self) -> Vec<Vec<u8>>

Session-level rejects received from the client, as engine serializations.

pub fn logon_requests(&self) -> Vec<Vec<u8>>

Logon requests received from the client, as engine serializations.

pub fn received_application(&self) -> Vec<Vec<u8>>

Application messages received from the client, as engine serializations.

pub fn stop(&self) -> Result<(), ConnectorError>

Stop the acceptor and join its threads.

Errors

Fails when the engine reports a stop error.