Public Member Functions
	~Listener () override=default
void	onMessageSending (char bytes, size_t size, Session ) override
void	onLogonReport (const Messaging::LogonReport msg, Session *) override
void	onLogoutReport (const Messaging::LogoutReport msg, Session *) override
void	onHeartBeat (const Messaging::HeartBeat msg, Session *) override
void	onError (const Messaging::Error msg, Session *) override
void	onNews (const Messaging::News msg, Session *) override
void	onSecurityDefinitionReport_Strategy (const Messaging::SecurityDefinitionReport_Strategy msg, Session *) override
void	onSecurityDefinitionReport (const Messaging::SecurityDefinitionReport msg, Session *) override
void	onSecurityDefinitionReject (const Messaging::SecurityDefinitionReject msg, Session *) override
void	onSecurityDefinitionReport_Product (const Messaging::SecurityDefinitionReport_Product msg, Session *) override
void	onIPReport (const Messaging::IPReport msg, Session *) override
void	onTraderLogonReport (const Messaging::TraderLogonReport msg, Session *) override
void	onTraderLogoutReport (const Messaging::TraderLogoutReport msg, Session *) override
void	onExecutionReport_New (const Messaging::ExecutionReport_New msg, Session *) override
void	onExecutionReport_Modify (const Messaging::ExecutionReport_Modify msg, Session *) override
void	onExecutionReport_Cancel (const Messaging::ExecutionReport_Cancel msg, Session *) override
void	onExecutionReport_Reject (const Messaging::ExecutionReport_Reject msg, Session *) override
void	onExecutionReport_Snapshot (const Messaging::ExecutionReport_Snapshot msg, Session *) override
void	onExecutionReport_Trade (const Messaging::ExecutionReport_Trade msg, Session *) override
void	onQuoteReport (const Messaging::QuoteReport msg, Session *) override
void	onNewOrderCrossReport (const Messaging::NewOrderCrossReport msg, Session *) override
void	onOrderMassCancelReport (const Messaging::OrderMassCancelReport msg, Session *) override
void	onMassQuoteReport (const Messaging::MassQuoteReport msg, Session *) override
void	onStateChange (SessionStateId::Enum newState, SessionStateId::Enum prevState, Session *) override
void	onError (SessionErrorReason::Enum, const std::string &description, Session *, Messaging::SbeMessage msg) override
void	onWarning (SessionWarningReason::Enum, const std::string &description, Session *, Messaging::SbeMessage msg) override
Public Member Functions inherited from SessionListener
virtual void	onSequenceReset (const Messaging::SequenceReset msg, Session *sn)
virtual void	onResendReport (const Messaging::ResendReport msg, Session *sn)
virtual void	onReceivedBytes (const char bytes, size_t size, const ReceivedDataTimestamp &timestamp, Session sn)

Public Attributes
std::promise< void >	traderLoggedOn

Additional Inherited Members
Protected Member Functions inherited from SessionListener
virtual	~SessionListener ()=0

Detailed Description

Definition at line 53 of file Listener.h.

Constructor & Destructor Documentation

◆ ~Listener()

~Listener ( )

overridedefault

Member Function Documentation

◆ onError() [1/2]

void onError	(	const Messaging::Error	msg,
		Session *	sn )

inlineoverridevirtual

Called when an Error message is received from the counterparty.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 79 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onError() [2/2]

void onError	(	SessionErrorReason::Enum	reason,
		const std::string &	description,
		Session *	sn,
		Messaging::SbeMessage	msg )

inlineoverridevirtual

Called when an error condition is detected by the session.

Parameters

reason	Error reason code.
description	Human-readable description of the problem.
sn	Session instance that detected the error.
msg	Message that caused the problem (may be invalid; check validity before use).

Reimplemented from SessionListener.

Definition at line 195 of file Listener.h.

    {
        std::cerr << "\nSession-level error: " << description;
 
        if(msg.valid())
        {
            std::cerr << ",\nCaused by the message: ";
            MessagePrinter::printMsg(msg);
        }
 
        std::cerr << std::endl;
    }

◆ onExecutionReport_Cancel()

void onExecutionReport_Cancel	(	const Messaging::ExecutionReport_Cancel	msg,
		Session *	sn )

inlineoverridevirtual

Called when an ExecutionReport_Cancel message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 145 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onExecutionReport_Modify()

void onExecutionReport_Modify	(	const Messaging::ExecutionReport_Modify	msg,
		Session *	sn )

inlineoverridevirtual

Called when an ExecutionReport_Modify message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 140 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onExecutionReport_New()

void onExecutionReport_New	(	const Messaging::ExecutionReport_New	msg,
		Session *	sn )

inlineoverridevirtual

Called when an ExecutionReport_New message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 135 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onExecutionReport_Reject()

void onExecutionReport_Reject	(	const Messaging::ExecutionReport_Reject	msg,
		Session *	sn )

inlineoverridevirtual

Called when an ExecutionReport_Reject message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 150 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onExecutionReport_Snapshot()

void onExecutionReport_Snapshot	(	const Messaging::ExecutionReport_Snapshot	msg,
		Session *	sn )

inlineoverridevirtual

Called when an ExecutionReport_Snapshot message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 155 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onExecutionReport_Trade()

void onExecutionReport_Trade	(	const Messaging::ExecutionReport_Trade	msg,
		Session *	sn )

inlineoverridevirtual

Called when an ExecutionReport_Trade message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 160 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onHeartBeat()

void onHeartBeat	(	const Messaging::HeartBeat	msg,
		Session *	sn )

inlineoverridevirtual

Called when a HeartBeat message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 74 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onIPReport()

void onIPReport	(	const Messaging::IPReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when an IPReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 109 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onLogonReport()

void onLogonReport	(	const Messaging::LogonReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a LogonReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 64 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onLogoutReport()

void onLogoutReport	(	const Messaging::LogoutReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a LogoutReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 69 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onMassQuoteReport()

void onMassQuoteReport	(	const Messaging::MassQuoteReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a MassQuoteReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 180 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onMessageSending()

void onMessageSending	(	char *	bytes,
		size_t	size,
		Session *	sn )

inlineoverridevirtual

Called right before an SBE message is sent to the wire.

Parameters

bytes	Pointer to the outbound buffer.
size	Size of `bytes` in bytes.
sn	Session instance that is sending the message.

Reimplemented from SessionListener.

Definition at line 58 of file Listener.h.

    {
        std::clog << "\nOutbound message:\n";
        MessagePrinter::printMsg(SbeMessage(bytes, static_cast<Messaging::MessageSize>(size)));
    }

◆ onNewOrderCrossReport()

void onNewOrderCrossReport	(	const Messaging::NewOrderCrossReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a NewOrderCrossReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 170 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onNews()

void onNews	(	const Messaging::News	msg,
		Session *	sn )

inlineoverridevirtual

Called when a News message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 84 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onOrderMassCancelReport()

void onOrderMassCancelReport	(	const Messaging::OrderMassCancelReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when an OrderMassCancelReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 175 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onQuoteReport()

void onQuoteReport	(	const Messaging::QuoteReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a QuoteReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 165 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onSecurityDefinitionReject()

void onSecurityDefinitionReject	(	const Messaging::SecurityDefinitionReject	msg,
		Session *	sn )

inlineoverridevirtual

Called when a SecurityDefinitionReject message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 99 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onSecurityDefinitionReport()

void onSecurityDefinitionReport	(	const Messaging::SecurityDefinitionReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a SecurityDefinitionReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 94 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onSecurityDefinitionReport_Product()

void onSecurityDefinitionReport_Product	(	const Messaging::SecurityDefinitionReport_Product	msg,
		Session *	sn )

inlineoverridevirtual

Called when a SecurityDefinitionReport_Product message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 104 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onSecurityDefinitionReport_Strategy()

void onSecurityDefinitionReport_Strategy	(	const Messaging::SecurityDefinitionReport_Strategy	msg,
		Session *	sn )

inlineoverridevirtual

Called when a SecurityDefinitionReport_Strategy message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 89 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onStateChange()

void onStateChange	(	SessionStateId::Enum	newState,
		SessionStateId::Enum	prevState,
		Session *	sn )

inlineoverridevirtual

Called when the session changes its state.

Parameters

newState	New session state.
prevState	Previous session state.
sn	Session instance whose state has changed.

Reimplemented from SessionListener.

Definition at line 185 of file Listener.h.

    {
        std::clog
            << "\nSession's state is changed, prevState="
            << SessionStateId::toString(prevState)
            << ", newState="
            << SessionStateId::toString(newState)
            << std::endl;
    }

◆ onTraderLogonReport()

void onTraderLogonReport	(	const Messaging::TraderLogonReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a TraderLogonReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 114 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
 
        if(const auto code = msg.exchangeCode())
        {
            const auto text = msg.text();
            assert(nullOpt != text);
 
            traderLoggedOn.set_exception(std::make_exception_ptr(std::runtime_error(Messaging::format(*code, *text))));
            return;
        }
 
        traderLoggedOn.set_value();
    }

◆ onTraderLogoutReport()

void onTraderLogoutReport	(	const Messaging::TraderLogoutReport	msg,
		Session *	sn )

inlineoverridevirtual

Called when a TraderLogoutReport message is received.

Parameters

msg	Received message.
sn	Session instance that received the message.

Reimplemented from SessionListener.

Definition at line 130 of file Listener.h.

    {
        std::clog << "\nReceived:\n" << msg << std::endl;
    }

◆ onWarning()

void onWarning	(	SessionWarningReason::Enum	reason,
		const std::string &	description,
		Session *	sn,
		Messaging::SbeMessage	msg )

inlineoverridevirtual

Called when a warning condition is detected by the session.

Parameters

reason	Warning reason code.
description	Human-readable description of the warning.
sn	Session instance that detected the warning.
msg	Message that caused the warning (may be invalid; check validity before use).

Reimplemented from SessionListener.

Definition at line 209 of file Listener.h.

    {
        std::cerr << "\nSession-level warning: " << description;
 
        if(msg.valid())
        {
            std::cerr << ",\nCaused by the message: ";
            MessagePrinter::printMsg(msg);
        }
 
        std::cerr << std::endl;
    }

Member Data Documentation

◆ traderLoggedOn

std::promise<void> traderLoggedOn

Definition at line 223 of file Listener.h.

Public Member Functions

Public Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ ~Listener()

Member Function Documentation

◆ onError() [1/2]

◆ onError() [2/2]

◆ onExecutionReport_Cancel()

◆ onExecutionReport_Modify()

◆ onExecutionReport_New()

◆ onExecutionReport_Reject()

◆ onExecutionReport_Snapshot()

◆ onExecutionReport_Trade()

◆ onHeartBeat()

◆ onIPReport()

◆ onLogonReport()

◆ onLogoutReport()

◆ onMassQuoteReport()

◆ onMessageSending()

◆ onNewOrderCrossReport()

◆ onNews()

◆ onOrderMassCancelReport()

◆ onQuoteReport()

◆ onSecurityDefinitionReject()

◆ onSecurityDefinitionReport()

◆ onSecurityDefinitionReport_Product()

◆ onSecurityDefinitionReport_Strategy()

◆ onStateChange()

◆ onTraderLogonReport()

◆ onTraderLogoutReport()

◆ onWarning()

Member Data Documentation

◆ traderLoggedOn