OnixS C++ ICE Binary Order Entry Handler 1.1.1
API Documentation
Loading...
Searching...
No Matches
PluggableStorage.cpp
Go to the documentation of this file.
1/*
2 * Copyright Onix Solutions Limited [OnixS]. All rights reserved.
3 *
4 * This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law
5 * and international copyright treaties.
6 *
7 * Access to and use of the software is governed by the terms of the applicable ONIXS Software
8 * Services Agreement (the Agreement) and Customer end user license agreements granting
9 * a non-assignable, non-transferable and non-exclusive license to use the software
10 * for it's own data processing purposes under the terms defined in the Agreement.
11 *
12 * Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part
13 * of this source code or associated reference material to any other location for further reproduction
14 * or redistribution, and any amendments to this copyright notice, are expressly prohibited.
15 *
16 * Any reproduction or redistribution for sale or hiring of the Software not in accordance with
17 * the terms of the Agreement is a violation of copyright law.
18 */
20
21#include <iostream>
22
23using namespace ONIXS_ICEBOE_NAMESPACE;
25
26#include "MySessionStorage.h"
27
28#include <Settings/Defaults.h>
29#include <Common/Helpers.h>
30#include <Common/Listener.h>
31#include <Common/Settings.h>
32#include <Common/Signal.h>
33#include <Common/Emulator.h>
34
35using namespace Samples;
36
37int main(int argc, char* argv[])
38{
39 // `--help` to show options.
41
42 try
43 {
45
46 auto settings = fillSettings(cfg);
47 const auto emulator = createEmulator(settings, cfg);
48
49 // Request Binary Order Gateway credentials from Binary Utility Service Gateway.
50 const auto bgwCredentials = receiveBgwCredentials(settings, cfg.host(), cfg.port());
51
52 MySessionStorage storage;
53 Listener listener;
54
55 // A 'BGW' session.
56 BgwSession bgwSession(settings, &listener, SessionStorageType::Pluggable, &storage);
57
58 bgwSession.connect(bgwCredentials);
59 bgwSession.send(Helper::createTraderLogonRequest(cfg.traderId(), cfg.traderPwd()));
60
61 Samples::wait(listener.traderLoggedOn).get();
62
63 bgwSession.send(Helper::createOrder(cfg.traderId()));
64
65 SignalHelper::waitUntilKey("disconnect the BGW session and terminate the application");
66
67 bgwSession.send(Helper::createTraderLogoutRequest(cfg.traderId())).disconnect();
68 }
69 catch (const std::exception& ex)
70 {
71 std::cerr << "EXCEPTION: " << ex.what() << std::endl;
72 return 1;
73 }
74
75 return 0;
76}
#define ONIXS_ICEBOE_NAMESPACE
Definition ABI.h:113
#define ONIXS_ICEBOE_MESSAGING_NAMESPACE
Definition ABI.h:114
int main(int argc, char *argv[])
Session & connect(const std::string &host, Port port, const std::string &ipSessionToken)
Establishes the connection.
Session & disconnect(const std::string &reason={})
Terminates the connection.
Session & send(Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &msg, Messaging::Timestamp sendingTime=UtcWatch::now())
Sends the message.
Definition Session.h:659
static MessageHolder< NewOrderRequest > createOrder(const std::string &traderId)
Definition Helpers.h:104
static MessageHolder< TraderLogoutRequest > createTraderLogoutRequest(const std::string &traderId)
Definition Helpers.h:95
static MessageHolder< TraderLogonRequest > createTraderLogonRequest(const std::string &traderId, const std::string &traderPwd)
Definition Helpers.h:77
std::promise< void > traderLoggedOn
Definition Listener.h:223
std::pair< std::unique_ptr< GatewayEmulatorThread< BusSessionGatewayListener > >, std::unique_ptr< GatewayEmulatorThread< GatewayListener > > > createEmulator(const SessionSettings &settings, const ConnectivityConfiguration &cfg, bool tcpDirect=false)
Definition Emulator.h:157
BgwCredentials receiveBgwCredentials(SessionSettings settings, std::string host, Port port)
Definition Listener.h:264
SessionSettings fillSettings(const LogonConfiguration &logonCfg, const ConnectivityConfiguration &connCfg, const SettingsConfiguration &settingsCfg)
Definition Settings.h:32
std::future< T > wait(Stack &stack, std::promise< T > &promise, std::chrono::seconds timeout=std::chrono::seconds{30})
Definition Listener.h:227
@ Pluggable
Pluggable Session Storage.
static void waitUntilKey(const std::string &message)
Definition Signal.h:57
static void manageSignals() noexcept
Definition Signal.h:46