2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef APPS_MQTTBROKER_MQTTBRIDGE_SOCKETCONTEXTFACTORY_H
43#define APPS_MQTTBROKER_MQTTBRIDGE_SOCKETCONTEXTFACTORY_H
45#include <core/socket/stream/SocketContextFactory.h>
47#ifndef DOXYGEN_SHOULD_SKIP_THIS
55 core::socket::stream::SocketContext*
create(core::socket::stream::SocketConnection* socketConnection)
final;
core::socket::stream::SocketContext * create(core::socket::stream::SocketConnection *socketConnection) final
static BridgeStore & instance()
bool loadAndValidate(const std::string &fileName)
void addEventReceiver(const std::shared_ptr< express::Response > &response, const std::string &lastEventId)
static SSEDistributor & instance()
int main(int argc, char *argv[])
static SocketClient< mqtt::bridge::SocketContextFactory > startClient(const std::string &instanceName, const std::function< void(typename SocketClient< mqtt::bridge::SocketContextFactory >::Config *)> &configurator)
static bool closeBridges()
static void handleAutoConnectControllers(core::socket::stream::AutoConnectControl *autoConnectController)
static void handleConnector(core::eventreceiver::ConnectEventReceiver *connectEventReceiver)
static std::set< core::eventreceiver::ConnectEventReceiver * > activeConnectors
static std::set< core::socket::stream::AutoConnectControl * > autoConnectControllers
static void reportState(const std::string &instanceName, const core::socket::SocketAddress &socketAddress, const core::socket::State &state)
static void handleConfig(net::config::ConfigInstance *configInstance)
static std::set< const net::config::ConfigInstance * > configInstances
static void startBridges()
static void restartBridges()
static HttpClient startClient(const std::string &instanceName, const std::function< void(typename HttpClient::Config *)> &configurator)