Methods for reading data from the BusMessage datatype.

[libplpbus.git] / src_test / test_server.cc

diff --git a/src_test/test_server.cc b/src_test/test_server.cc
index 1a6a17f1113190e720b4ad4cb909b6631f861a0c..5c2677604f88deceeea1f3e0eb307bf98217d5ba 100644 (file)
--- a/src_test/test_server.cc
+++ b/src_test/test_server.cc
@@ -6,6 +6,8 @@
 using namespace std;
 using namespace plpbus;
 
+#define MSG_ID_HELLO   33
+
 class ServerListenerImpl : public IServerListener
 {
        public:
@@ -23,16 +25,18 @@ int ServerListenerImpl::request_received(const char *msg_req_param, char **msg_r
 }
 
 int ServerListenerImpl::request_received(const BusMessage *msg_req_param, BusMessage **msg_rsp_param) {
-       log_debug("request_received(BusMessage *) started\n");
-       *msg_rsp_param = new BusMessage();
+       long    type;
+       int     err_flg;
+
+       type    = ((BusMessage *)msg_req_param)->get_type(&err_flg);
+       log_debug("request_received, msg type: %ld\n", type);
+       *msg_rsp_param = new BusMessage(MSG_ID_HELLO);
        double dbl = (double)1.0;
        (*msg_rsp_param)->add_double_parameter("rsp_param_double", dbl);
-       log_debug("request_received(BusMessage *) done\n");
        return 0;
 }
 
-int main(int argc, char** argv)
-{
+int main(int argc, char** argv) {
        BusServer               *server;
        ServerListenerImpl      *listener;