HandlerImpl.Processing.cpp

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.
*/
#include <OnixS/SgxTitan/Trading/OUCH/Defines.h>
#include <OnixS/SgxTitan/Trading/OUCH/Enumerations.h>
#include <OnixS/SgxTitan/Trading/OUCH/Messages.In.h>

#include "ListenerHolder.h"
#include "ProtocolFormatting.h"
#include "HandlerImpl.h"
#include "AuditTrailDumper.h"


using namespace OnixS::SgxTitan::Trading::Ouch;
using namespace OnixS::SgxTitan::Trading::Ouch::Implementation;


void HandlerImpl::processData(const void* dataPtr, UInt16 messageLength)
{
    const IncomingMessage message(dataPtr, messageLength);
    const InboundMessageTypes::Enum messageType = message.type();

    if (InboundMessageTypes::OrderAccepted == messageType)
    {
        OrderAccepted::validateSize(messageLength);
        const OrderAccepted& msg = OrderAccepted(dataPtr, messageLength);

        log(ONIXS_LOG_DEBUG[this] << "Received " << msg);

        listenerHolder_->invoke(msg);
    }
    else if (InboundMessageTypes::OrderRejected == messageType)
    {
        OrderRejected::validateSize(messageLength);
        const OrderRejected& msg = OrderRejected(dataPtr, messageLength);

        log(ONIXS_LOG_DEBUG[this] << "Received " << msg);

        listenerHolder_->invoke(msg);
    }
    else if (InboundMessageTypes::OrderReplaced == messageType)
    {
        OrderReplaced::validateSize(messageLength);
        const OrderReplaced& msg = OrderReplaced(dataPtr, messageLength);

        log(ONIXS_LOG_DEBUG[this] << "Received " << msg);

        listenerHolder_->invoke(msg);
    }
    else if (InboundMessageTypes::OrderCancelled == messageType)
    {
        OrderCancelled::validateSize(messageLength);
        const OrderCancelled& msg = OrderCancelled(dataPtr, messageLength);

        log(ONIXS_LOG_DEBUG[this] << "Received " << msg);

        listenerHolder_->invoke(msg);
    }
    else if (InboundMessageTypes::OrderExecuted == messageType)
    {
        OrderExecuted::validateSize(messageLength);
        const OrderExecuted& msg = OrderExecuted(dataPtr, messageLength);

        log(ONIXS_LOG_DEBUG[this] << "Received " << msg);

        listenerHolder_->invoke(msg);
    }
    else
        log(ONIXS_LOG_WARN[this] << "Received unknown message, type = " << static_cast<Binary1>(message.type()));

    if (auditTrailDumper_)
        auditTrailDumper_->onInboundMessage(dataPtr, messageLength);
}