commit 66b65ab5d365a6abaaee4921f70de751891b3c05
author Victor Dogaru <vdogaru@apache.org> Fri Mar 18 16:35:43 2016 -0700
committer Victor Dogaru <vdogaru@apache.org> Fri Mar 18 16:35:43 2016 -0700
tree 09f56b4450a8802c28afb43857c8297b93ce23f5
parent 8ef16b5690bdc09a4ce83e9e4998f9770647da83

Add JobMXBean health and lastError attributes

topology/src/main/java/quarks/samples/topology/DevelopmentSampleJobMXBean.java

diff --git a/topology/src/main/java/quarks/samples/topology/DevelopmentSampleJobMXBean.java b/topology/src/main/java/quarks/samples/topology/DevelopmentSampleJobMXBean.java
index 0e45bbe..0ce2dec 100644
--- a/topology/src/main/java/quarks/samples/topology/DevelopmentSampleJobMXBean.java
+++ b/topology/src/main/java/quarks/samples/topology/DevelopmentSampleJobMXBean.java
@@ -41,7 +41,7 @@
         StringBuffer sbuf = new StringBuffer();
         sbuf.append(DevelopmentProvider.JMX_DOMAIN);
         sbuf.append(":interface=");
-        sbuf.append(ObjectName.quote("quarks.graph.execution.mbeans.JobMXBean"));
+        sbuf.append(ObjectName.quote("quarks.execution.mbeans.JobMXBean"));
         sbuf.append(",type=");
         sbuf.append(ObjectName.quote("job"));
         sbuf.append(",*");
@@ -60,8 +60,12 @@
         	String jobName = (String) mBeanServer.getAttribute(objectName, "Name");
         	String jobCurState = (String) mBeanServer.getAttribute(objectName, "CurrentState");
         	String jobNextState = (String) mBeanServer.getAttribute(objectName, "NextState");
+            String jobHealth = (String) mBeanServer.getAttribute(objectName, "Health");
+            String jobLastError = (String) mBeanServer.getAttribute(objectName, "LastError");
         	
-        	System.out.println("Found a job with JobId: " + jobId + " Name: " + jobName + " CurrentState: " + jobCurState + " NextState: " + jobNextState);
+        	System.out.println("Found a job with JobId: " + jobId + " Name: " + jobName + 
+                    " CurrentState: " + jobCurState + " NextState: " + jobNextState + 
+                    " Health: " + jobHealth + " LastError: \"" + jobLastError + "\"");
         }
     }
 }