Leosac
0.8.0
Open Source Access Control
MessageBus.hpp
Go to the documentation of this file.
1
/*
2
Copyright (C) 2014-2016 Leosac
3
4
This file is part of Leosac.
5
6
Leosac is free software: you can redistribute it and/or modify
7
it under the terms of the GNU Affero General Public License as published by
8
the Free Software Foundation, either version 3 of the License, or
9
(at your option) any later version.
10
11
Leosac is distributed in the hope that it will be useful,
12
but WITHOUT ANY WARRANTY; without even the implied warranty of
13
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14
GNU Affero General Public License for more details.
15
16
You should have received a copy of the GNU Affero General Public License
17
along with this program. If not, see <http://www.gnu.org/licenses/>.
18
*/
19
20
#pragma once
21
#include "zmqpp/zmqpp.hpp"
22
29
class
MessageBus
30
{
31
public
:
32
MessageBus
(zmqpp::context &ctx);
33
~MessageBus
();
34
35
private
:
36
zmqpp::actor *
actor_
;
37
42
bool
run
(zmqpp::socket *pipe);
43
44
zmqpp::context &
ctx_
;
45
46
zmqpp::socket *
pub_
;
47
zmqpp::socket *
pull_
;
48
49
50
void
handle_pipe
(zmqpp::socket *pipe);
51
void
handle_pull
();
52
53
bool
running_
;
54
};
MessageBus::running_
bool running_
Definition:
MessageBus.hpp:53
MessageBus::run
bool run(zmqpp::socket *pipe)
The method that will be run in the child thread.
Definition:
MessageBus.cpp:38
MessageBus::handle_pull
void handle_pull()
Definition:
MessageBus.cpp:81
MessageBus::handle_pipe
void handle_pipe(zmqpp::socket *pipe)
Definition:
MessageBus.cpp:70
MessageBus::MessageBus
MessageBus(zmqpp::context &ctx)
Definition:
MessageBus.cpp:23
MessageBus::pull_
zmqpp::socket * pull_
Definition:
MessageBus.hpp:47
MessageBus::pub_
zmqpp::socket * pub_
Definition:
MessageBus.hpp:46
MessageBus
Implements a message bus (running in its own thread) that use 2 sockets.
Definition:
MessageBus.hpp:29
MessageBus::ctx_
zmqpp::context & ctx_
Definition:
MessageBus.hpp:44
MessageBus::actor_
zmqpp::actor * actor_
Definition:
MessageBus.hpp:36
MessageBus::~MessageBus
~MessageBus()
Definition:
MessageBus.cpp:33
src
core
MessageBus.hpp
Generated on Tue Mar 22 2022 10:48:20 for Leosac by
1.8.17