using namespace std;
using namespace plpbus;
-#define MSG_ID_HELLO 0
+#define MSG_ID_HELLO 33
class ServerListenerImpl : public IServerListener
{
}
int ServerListenerImpl::request_received(const BusMessage *msg_req_param, BusMessage **msg_rsp_param) {
- log_debug("request_received(BusMessage *) started\n");
+ long type;
+
+ type = 0;
+ ((BusMessage *)msg_req_param)->get_type(&type);
+ 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;