135 lines
4.1 KiB
C++
135 lines
4.1 KiB
C++
/* -*- C++ -*- */
|
|
|
|
/****************************************************************************
|
|
** Copyright (c) 2001-2014
|
|
**
|
|
** This file is part of the QuickFIX FIX Engine
|
|
**
|
|
** This file may be distributed under the terms of the quickfixengine.org
|
|
** license as defined by quickfixengine.org and appearing in the file
|
|
** LICENSE included in the packaging of this file.
|
|
**
|
|
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
|
|
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
|
|
**
|
|
** See http://www.quickfixengine.org/LICENSE for licensing information.
|
|
**
|
|
** Contact ask@quickfixengine.org if any conditions of this licensing are
|
|
** not clear to you.
|
|
**
|
|
****************************************************************************/
|
|
|
|
#ifndef FIXT11_MESSAGECRACKER_H
|
|
#define FIXT11_MESSAGECRACKER_H
|
|
|
|
|
|
#include "../SessionID.h"
|
|
#include "../Exceptions.h"
|
|
|
|
#include "../fixt11/Message.h"
|
|
|
|
namespace FIXT11
|
|
{
|
|
class Heartbeat;
|
|
class TestRequest;
|
|
class ResendRequest;
|
|
class Reject;
|
|
class SequenceReset;
|
|
class Logout;
|
|
class Logon;
|
|
|
|
class MessageCracker
|
|
{
|
|
public:
|
|
virtual ~MessageCracker() {}
|
|
virtual void onMessage( const Message&, const FIX::SessionID& )
|
|
{ throw FIX::UnsupportedMessageType(); }
|
|
virtual void onMessage( Message&, const FIX::SessionID& )
|
|
{ throw FIX::UnsupportedMessageType(); }
|
|
virtual void onMessage( const Heartbeat&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( const TestRequest&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( const ResendRequest&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( const Reject&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( const SequenceReset&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( const Logout&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( const Logon&, const FIX::SessionID& )
|
|
{}
|
|
virtual void onMessage( Heartbeat&, const FIX::SessionID& ) {}
|
|
virtual void onMessage( TestRequest&, const FIX::SessionID& ) {}
|
|
virtual void onMessage( ResendRequest&, const FIX::SessionID& ) {}
|
|
virtual void onMessage( Reject&, const FIX::SessionID& ) {}
|
|
virtual void onMessage( SequenceReset&, const FIX::SessionID& ) {}
|
|
virtual void onMessage( Logout&, const FIX::SessionID& ) {}
|
|
virtual void onMessage( Logon&, const FIX::SessionID& ) {}
|
|
|
|
public:
|
|
void crack( const Message& message,
|
|
const FIX::SessionID& sessionID )
|
|
{
|
|
const std::string& msgTypeValue
|
|
= message.getHeader().getField( FIX::FIELD::MsgType );
|
|
|
|
if( msgTypeValue == "0" )
|
|
onMessage( (const Heartbeat&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "1" )
|
|
onMessage( (const TestRequest&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "2" )
|
|
onMessage( (const ResendRequest&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "3" )
|
|
onMessage( (const Reject&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "4" )
|
|
onMessage( (const SequenceReset&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "5" )
|
|
onMessage( (const Logout&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "A" )
|
|
onMessage( (const Logon&)message, sessionID );
|
|
else onMessage( message, sessionID );
|
|
}
|
|
|
|
void crack( Message& message,
|
|
const FIX::SessionID& sessionID )
|
|
{
|
|
FIX::MsgType msgType;
|
|
message.getHeader().getField(msgType);
|
|
std::string msgTypeValue = msgType.getValue();
|
|
|
|
if( msgTypeValue == "0" )
|
|
onMessage( (Heartbeat&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "1" )
|
|
onMessage( (TestRequest&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "2" )
|
|
onMessage( (ResendRequest&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "3" )
|
|
onMessage( (Reject&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "4" )
|
|
onMessage( (SequenceReset&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "5" )
|
|
onMessage( (Logout&)message, sessionID );
|
|
else
|
|
if( msgTypeValue == "A" )
|
|
onMessage( (Logon&)message, sessionID );
|
|
else onMessage( message, sessionID );
|
|
}
|
|
|
|
};
|
|
}
|
|
|
|
#endif
|