MessageListener.h

Go to the documentation of this file.

/*
* Copyright Onix Solutions Limited [OnixS]. All rights reserved.
*
* This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law
* and international copyright treaties.
*
* Access to and use of the software is governed by the terms of the applicable ONIXS Software
* Services Agreement (the Agreement) and Customer end user license agreements granting
* a non-assignable, non-transferable and non-exclusive license to use the software
* for it's own data processing purposes under the terms defined in the Agreement.
*
* Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part
* of this source code or associated reference material to any other location for further reproduction
* or redistribution, and any amendments to this copyright notice, are expressly prohibited.
*
* Any reproduction or redistribution for sale or hiring of the Software not in accordance with
* the terms of the Agreement is a violation of copyright law.
*/

#pragma once

#include <OnixS/Euronext/MarketData/OptiqMdg/messaging/Forwards.h>
#include <OnixS/Euronext/MarketData/OptiqMdg/Defines.h>

namespace OnixS {
namespace Euronext {
namespace MarketData {
namespace OptiqMdg {
namespace Messaging {
    class SbeMessage;
}

    /// Message listener
    class ONIXS_EURONEXT_OPTIQMDG_API MessageListener
    {
        public:
            virtual void onStartOfDay(const Messaging::StartOfDay&, const DataSource&) {}
            virtual void onEndOfDay(const Messaging::EndOfDay&, const DataSource&) {}
            virtual void onHealthStatus(const Messaging::HealthStatus&, const DataSource&) {}
            virtual void onTechnicalNotification(const Messaging::TechnicalNotification&, const DataSource&) {}
            virtual void onMarketUpdate(const Messaging::MarketUpdate&, const DataSource&) {}
            virtual void onOrderUpdate(const Messaging::OrderUpdate&, const DataSource&) {}
            virtual void onPriceUpdate(const Messaging::PriceUpdate&, const DataSource&) {}
            virtual void onFullTradeInformation(const Messaging::FullTradeInformation&, const DataSource&) {}
            virtual void onMarketStatusChange(const Messaging::MarketStatusChange&, const DataSource&) {}
            virtual void onTimetable(const Messaging::Timetable&, const DataSource&) {}
            virtual void onStandingData(const Messaging::StandingData&, const DataSource&) {}
            virtual void onRealTimeIndex(const Messaging::RealTimeIndex&, const DataSource&) {}
            virtual void onStatistics(const Messaging::Statistics&, const DataSource&) {}
            virtual void onIndexSummary(const Messaging::IndexSummary&, const DataSource&) {}
            virtual void onStrategyStandingData(const Messaging::StrategyStandingData&, const DataSource&) {}
            virtual void onContractStandingData(const Messaging::ContractStandingData&, const DataSource&) {}
            virtual void onOutrightStandingData(const Messaging::OutrightStandingData&, const DataSource&) {}
            virtual void onLongOrderUpdate(const Messaging::LongOrderUpdate&, const DataSource&) {}
            virtual void onLisPackageStructure(const Messaging::LisPackageStructure&, const DataSource&) {}
            virtual void onApaQuotes(const Messaging::ApaQuotes&, const DataSource&) {}
            virtual void onApaStandingData(const Messaging::ApaStandingData&, const DataSource&) {}
            virtual void onApaFullTradeInformation(const Messaging::ApaFullTradeInformation&, const DataSource&) {}
            virtual void onBfInstrumentReference(const Messaging::BfInstrumentReference&, const DataSource&) {}
            virtual void onBfTrade(const Messaging::BfTrade&, const DataSource&) {}
            virtual void onBfnav(const Messaging::Bfnav&, const DataSource&) {}
            virtual void onBfInstrumentSuspension(const Messaging::BfInstrumentSuspension&, const DataSource&) {}
            virtual void onStartOfSnapshot(const Messaging::StartOfSnapshot&, const DataSource&) {}
            virtual void onEndOfSnapshot(const Messaging::EndOfSnapshot&, const DataSource&) {}

            virtual void onUnknownMessage(const Messaging::SbeMessage&, const DataSource&) {}

            virtual void onRealtimeGap() {}
            virtual void onRealtimeInactivity() {}

            virtual void onSnapshotGap() {}
            virtual void onSnapshotInactivity() {}

        protected:
            virtual ~MessageListener() = 0;
    };
}
}
}
}