MQTTSuite
Loading...
Searching...
No Matches
SocketContextFactory.h
Go to the documentation of this file.
1
/*
2
* MQTTSuite - A lightweight MQTT Integration System
3
* Copyright (C) Volker Christian <me@vchrist.at>
4
* 2022, 2023, 2024, 2025, 2026
5
*
6
* This program is free software: you can redistribute it and/or modify it
7
* under the terms of the GNU General Public License as published by the Free
8
* Software Foundation, either version 3 of the License, or (at your option)
9
* any later version.
10
*
11
* This program is distributed in the hope that it will be useful, but WITHOUT
12
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
14
* more details.
15
*
16
* You should have received a copy of the GNU General Public License along
17
* with this program. If not, see <https://www.gnu.org/licenses/>.
18
*/
19
20
/*
21
* MIT License
22
*
23
* Permission is hereby granted, free of charge, to any person obtaining a copy
24
* of this software and associated documentation files (the "Software"), to deal
25
* in the Software without restriction, including without limitation the rights
26
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
27
* copies of the Software, and to permit persons to whom the Software is
28
* furnished to do so, subject to the following conditions:
29
*
30
* The above copyright notice and this permission notice shall be included in
31
* all copies or substantial portions of the Software.
32
*
33
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
34
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
35
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
36
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
37
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
38
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
39
* THE SOFTWARE.
40
*/
41
42
#
ifndef
APPS_MQTTBROKER_MQTTBRIDGE_SOCKETCONTEXTFACTORY_H
43
#
define
APPS_MQTTBROKER_MQTTBRIDGE_SOCKETCONTEXTFACTORY_H
44
45
#
include
<
core
/
socket
/
stream
/
SocketContextFactory
.
h
>
// IWYU pragma: export
46
47
#
ifndef
DOXYGEN_SHOULD_SKIP_THIS
48
49
#
endif
50
51
namespace
mqtt::
bridge
{
52
53
class
SocketContextFactory
:
public
core::socket::stream::SocketContextFactory {
54
private
:
55
core::socket::stream::SocketContext*
create
(core::socket::stream::SocketConnection* socketConnection)
final
;
56
};
57
58
}
// namespace mqtt::bridge
59
60
#
endif
// APPS_MQTTBROKER_MQTTBRIDGE_SOCKETCONTEXTFACTORY_H
mqtt::bridge::ConfigBridge
Definition
ConfigBridge.h:56
mqtt::bridge::SocketContextFactory
Definition
SocketContextFactory.h:53
mqtt::bridge::SocketContextFactory::create
core::socket::stream::SocketContext * create(core::socket::stream::SocketConnection *socketConnection) final
Definition
SocketContextFactory.cpp:61
mqtt::bridge::lib::BridgeStore
Definition
BridgeStore.h:60
mqtt::bridge::lib::BridgeStore::instance
static BridgeStore & instance()
Definition
BridgeStore.cpp:65
mqtt::bridge::lib::BridgeStore::activateStaged
void activateStaged()
Definition
BridgeStore.cpp:165
mqtt::bridge::lib::BridgeStore::loadAndValidate
bool loadAndValidate(const std::string &fileName)
Definition
BridgeStore.cpp:71
mqtt::bridge::lib::SSEDistributor
Definition
SSEDistributor.h:63
mqtt::bridge::lib::SSEDistributor::bridgesStopping
void bridgesStopping()
Definition
SSEDistributor.cpp:140
mqtt::bridge::lib::SSEDistributor::bridgesStarting
void bridgesStarting()
Definition
SSEDistributor.cpp:130
mqtt::bridge::lib::SSEDistributor::addEventReceiver
void addEventReceiver(const std::shared_ptr< express::Response > &response, const std::string &lastEventId)
Definition
SSEDistributor.cpp:74
mqtt::bridge::lib::SSEDistributor::instance
static SSEDistributor & instance()
Definition
SSEDistributor.cpp:68
main
int main(int argc, char *argv[])
Definition
json-schema-validate.cpp:46
startClient
static SocketClient< mqtt::bridge::SocketContextFactory > startClient(const std::string &instanceName, const std::function< void(typename SocketClient< mqtt::bridge::SocketContextFactory >::Config *)> &configurator)
Definition
mqttbridge.cpp:197
closeBridges
static bool closeBridges()
Definition
mqttbridge.cpp:151
flowControllers
static std::map< uint64_t, core::socket::stream::ClientFlowController * > flowControllers
Definition
mqttbridge.cpp:115
handleFlowControllers
static void handleFlowControllers(core::socket::stream::ClientFlowController *clientFlowController)
Definition
mqttbridge.cpp:137
reportState
static void reportState(const std::string &instanceName, const core::socket::SocketAddress &socketAddress, const core::socket::State &state)
Definition
mqttbridge.cpp:179
startBridges
static void startBridges()
Definition
mqttbridge.cpp:267
restart
static bool restart
Definition
mqttbridge.cpp:117
restartBridges
static void restartBridges()
Definition
mqttbridge.cpp:121
startClient
static HttpClient startClient(const std::string &instanceName, const std::function< void(typename HttpClient::Config *)> &configurator)
Definition
mqttbridge.cpp:220
express
Definition
SSEDistributor.h:45
mqtt::bridge::lib
Definition
Bridge.cpp:59
mqtt::bridge
Definition
ConfigBridge.cpp:48
mqttbridge
SocketContextFactory.h
Generated on
for MQTTSuite by
1.15.0