From: Michal Voců <michal@ruk.cuni.cz>
Date: Mon, 4 Apr 2011 13:07:43 +0000 (+0000)
Subject: send jobid as part of status notification
X-Git-Tag: glite-lb-client_R_5_0_4_3~12
X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=65f07cb8c9f6c44ace692fcd4fbaa37d27d130ee;p=jra1mw.git

send jobid as part of status notification
---

diff --git a/org.glite.lb.logger-msg/src/activemq_cpp_plugin.cpp b/org.glite.lb.logger-msg/src/activemq_cpp_plugin.cpp
index 21098d3..8d6385a 100644
--- a/org.glite.lb.logger-msg/src/activemq_cpp_plugin.cpp
+++ b/org.glite.lb.logger-msg/src/activemq_cpp_plugin.cpp
@@ -124,6 +124,12 @@ OutputPlugin::createMessage(edg_wll_JobStat &state_out)
 	std::ostrstream body;
 
 	body << "{";
+	/* jobid */
+	s = glite_jobid_unparse(state_out.jobId);
+	if(s) {
+		body << "jobid: \"" << s << "\", ";
+		free(s);
+	}
 	/* ownerDn */
 	if(state_out.owner) {
 		body << "ownerDn: \"" << state_out.owner << "\", ";
@@ -233,7 +239,7 @@ OutputPlugin::cleanup()
 		try {
 			connection->close();
 		} catch(cms::CMSException &e) {
-			glite_common_log(IL_LOG_CATEGORY, LOG_PRIORITY_DEBUG, "activemq_cpp_plugin: connection close exception: %s", e.what());
+			glite_common_log(IL_LOG_CATEGORY, LOG_PRIORITY_DEBUG, "activemq_cpp_plugin: connection close  exception: %s", e.what());
 		}
 		try {
 			delete connection;