-
Notifications
You must be signed in to change notification settings - Fork 0
/
ExchangeCommunicator.h
37 lines (31 loc) · 1.16 KB
/
ExchangeCommunicator.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
#pragma once
#include "Queue.h"
#include "MessageParser.h"
#include "Constant.h"
#include "ExchangeDataHandler.h"
#include "MessageParserADSM.h"
#include "Publisher.h"
#include "ace/Connector.h"
#include "ace/Reactor.h"
class CExchangeCommunicator
{
public:
STExchangeConnectionInfo m_ExeConInfo;
CQueue<std::string>* m_QueueRawMsg; // Raw Message (From Exchange) Queue
CQueue<CParsedMessage>* m_QueueParsedMessage; // Parsed Message (From Message Parser) Queue
IMessageParser* m_MessageParser;
CExchangeDataHandler* m_ExDataHandler; // Ace Service Handler Receiving Data
CPublisher* m_Publisher;
private:
ACE_Connector<CExchangeDataHandler, ACE_SOCK_CONNECTOR> m_Connector; // ACE_Connector
ACE_thread_t m_processorThreadID;
ACE_hthread_t m_processorThreadHandle;
public:
CExchangeCommunicator();
CExchangeCommunicator(STExchangeConnectionInfo _ExConInfo);
virtual ~CExchangeCommunicator();
int ConnectToExchange();
static void* Start_( void * pParam );
void Start_Callback();
};
typedef std::vector<CExchangeCommunicator*> CExchangeCommunicatorList;