Struct fix_rs::fixt::engine::Engine

pub struct Engine { /* fields omitted */ }

Methods

impl Engine

fn new(
    message_dictionary: HashMap<&'static [u8], Box<BuildFIXTMessage + Send>>,
    max_message_size: u64
) -> Result<Engine, Error>

fn add_connection<A: ToSocketAddrs>(
    &mut self,
    fix_version: FIXVersion,
    default_message_version: MessageVersion,
    sender_comp_id: &[u8],
    target_comp_id: &[u8],
    address: A
) -> Option<Connection>

fn add_listener<A: ToSocketAddrs>(
    &mut self,
    sender_comp_id: &[u8],
    address: A
) -> Result<Option<Listener>, Error>

fn send_message<T: 'static + FIXTMessage + Send>(
    &mut self,
    connection: Connection,
    message: T
)

fn send_message_box(
    &mut self,
    connection: Connection,
    message: Box<FIXTMessage + Send>
)

fn send_message_box_with_message_version<MV: Into<Option<MessageVersion>>>(
    &mut self,
    connection: Connection,
    message_version: MV,
    message: Box<FIXTMessage + Send>
)

fn send_resend_response(
    &mut self,
    connection: Connection,
    response: Vec<ResendResponse>
)

fn approve_new_connection<IMSN: Into<Option<u64>>>(
    &mut self,
    connection: Connection,
    message: Box<Logon>,
    inbound_msg_seq_num: IMSN
)

fn reject_new_connection(
    &mut self,
    connection: Connection,
    reason: Option<Vec<u8>>
)

fn logout(&mut self, connection: Connection)

fn poll<D: Into<Option<Duration>>>(
    &mut self,
    duration: D
) -> Option<EngineEvent>

Trait Implementations

impl Drop for Engine

fn drop(&mut self)

A method called when the value goes out of scope.