From 65f07cb8c9f6c44ace692fcd4fbaa37d27d130ee Mon Sep 17 00:00:00 2001 From: =?utf8?q?Michal=20Voc=C5=AF?= Date: Mon, 4 Apr 2011 13:07:43 +0000 Subject: [PATCH] send jobid as part of status notification --- org.glite.lb.logger-msg/src/activemq_cpp_plugin.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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; -- 1.8.2.3