1 files changed, 4 insertions, 13 deletions
diff --git a/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java b/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java
index 62a2673..43bc6d8 100644
--- a/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java
+++ b/src/main/java/org/jenkinsci/plugins/activemq/ActiveMqRunListener.java
@@ -4,33 +4,24 @@ import hudson.Extension;
 import hudson.model.Build;
 import hudson.model.TaskListener;
 import hudson.model.listeners.RunListener;
+import jenkins.model.Jenkins;
 
 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);
+        ActiveMqPlugin plugin = Jenkins.getInstance().getPlugin(ActiveMqPlugin.class);
+        plugin.onCompleted(build, listener);
 
-        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());
+//        activeMqClient.sendMessage(build.getProject().getName(), build.getNumber(), build.getResult().toString());
 
 //        Jenkins jenkins = Jenkins.getInstance();
 //        List<AbstractProject> projects = jenkins.getAllItems(AbstractProject.class);