4 #include "plpbus/BusServer.hh"
7 using namespace plpbus;
11 class ServerListenerImpl : public IServerListener
14 inline ServerListenerImpl() {}
15 virtual ~ServerListenerImpl() {}
16 virtual int request_received(const char *msg_req, char **msg_rsp);
17 virtual int request_received(const BusMessage *msg_req, BusMessage **msg_rsp);
20 int ServerListenerImpl::request_received(const char *msg_req_param, char **msg_rsp_param) {
21 log_debug("request_received(), request_param: %s\n", msg_req_param);
22 *msg_rsp_param = strdup("jee");
23 log_debug("request_received(), response param set: %s\n", *msg_rsp_param);
27 int ServerListenerImpl::request_received(const BusMessage *msg_req_param, BusMessage **msg_rsp_param) {
28 log_debug("request_received(BusMessage *) started\n");
29 *msg_rsp_param = new BusMessage(MSG_ID_HELLO);
30 double dbl = (double)1.0;
31 (*msg_rsp_param)->add_double_parameter("rsp_param_double", dbl);
32 log_debug("request_received(BusMessage *) done\n");
36 int main(int argc, char** argv)
39 ServerListenerImpl *listener;
42 log_info("starting server\n");
43 server = new BusServer();
45 listener = new ServerListenerImpl();
46 server->add_server_listener(listener);
47 server->launch(argv[1]);
50 log_info("usage: give server name as a parameter\n");