1 files changed, 42 insertions, 0 deletions
diff --git a/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java b/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java
new file mode 100644
index 0000000..62a2673
--- /dev/null
+++ b/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java
@@ -0,0 +1,42 @@
+package org.jenkinsci.plugins.activemq;
+
+import hudson.Extension;
+import hudson.model.Build;
+import hudson.model.TaskListener;
+import hudson.model.listeners.RunListener;
+
+import javax.annotation.Nonnull;
+
+@Extension
+public class ActiveMqRunListener extends RunListener<Build> {
+
+    private final ActiveMqClient activeMqClient;
+
+    public ActiveMqRunListener() {
+        super(Build.class);
+
+        System.out.println("JbpmRunListener.JbpmRunListener");
+
+        activeMqClient = new ActiveMqClient("tcp://localhost:61616");
+    }
+
+    @Override
+    public void onCompleted(Build build, @Nonnull TaskListener listener) {
+        System.out.println("JbpmRunListener.onCompleted");
+        System.out.println("build = " + build);
+
+        System.out.println("build variables");
+        for (Object o : build.getBuildVariables().entrySet()) {
+            System.out.println(o);
+        }
+
+        activeMqClient.sendMessage(build.getProject().getName(), build.getNumber(), build.getResult().toString());
+
+//        Jenkins jenkins = Jenkins.getInstance();
+//        List<AbstractProject> projects = jenkins.getAllItems(AbstractProject.class);
+//        for (AbstractProject project : projects) {
+//            System.out.println("project.getPronoun() = " + project.getPronoun());
+//            System.out.println("project.getName() = " + project.getName());
+//        }
+    }
+}