4 #include "plpbus/BusServer.hh"
7 using namespace plpbus;
9 #define MSG_ID_HELLO 33
11 class ServerListenerImpl : public IServerListener
14 inline ServerListenerImpl() {}
15 virtual ~ServerListenerImpl() {}
16 virtual int request_received(const char *msg_req, const char **msg_rsp);
17 virtual int request_received(const BusMessage *msg_req, const BusMessage *msg_rsp);
20 int ServerListenerImpl::request_received(const char *msg_req_param, const char **msg_rsp_param) {
21 log_debug("request_received(), request_param: %s\n", msg_req_param);
22 *msg_rsp_param = "jee";
23 log_debug("request_received(), response param set: %s\n", *msg_rsp_param);
27 int ServerListenerImpl::request_received(const BusMessage *msg_req_param, const BusMessage *msg_rsp_param) {
31 type = ((BusMessage *)msg_req_param)->get_type(&err_flg);
32 log_debug("request_received, msg type: %ld\n", type);
33 //*msg_rsp_param = new BusMessage(MSG_ID_HELLO);
34 double dbl = (double)1.0;
35 ((BusMessage *)msg_rsp_param)->add_double_parameter("rsp_param_double", dbl);
39 int main(int argc, char** argv) {
41 ServerListenerImpl *listener;
44 log_info("starting server\n");
45 server = new BusServer();
48 listener = new ServerListenerImpl();
49 if (listener != NULL) {
50 server->add_server_listener(listener);
51 server->launch(argv[1]);
58 log_info("usage: give server name as a parameter\n");