#define CONV_JSON_CLIENT_CONNECT_TIME "client_connect_time"
#define CONV_JSON_CLIENT_CLIENT_ID "client_id"
#define CONV_JSON_SECURE_MODE "secure_mode"
+#define CONV_JSON_TARGET_CLIENT_ID "target_client_id"
#define CONV_JSON_ON_START "onStart"
#define CONV_JSON_ON_CONNECT "onConnect"
Json payload;
requestObj->getPayloadFromDescription(&payload);
+ string targetClient;
- (*iter)->application->publish("d2d_service_message", payload.str().c_str(), requestObj->getBinary(), requestObj->getBinaryLength(), NULL);
- _D("publishing done");
+ payload.get(NULL, CONV_JSON_TARGET_CLIENT_ID, &targetClient);
+
+ if (targetClient.empty()) {
+ (*iter)->application->publish("d2d_service_message", payload.str().c_str(), requestObj->getBinary(), requestObj->getBinaryLength(), NULL);
+ _D("publishing broadcast done");
+ } else {
+ (*iter)->application->publish("d2d_service_message", payload.str().c_str(), targetClient.c_str(), requestObj->getBinary(), requestObj->getBinaryLength(), NULL);
+ }
return CONV_ERROR_NONE;
}
}