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 
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