Updated readMe and fixed indentations.

Spydernaz · Sep 1, 2017 · cb651ae · cb651ae
1 parent 63a91f3
commit cb651ae
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/plugins/service-monitor-activemq/ReadMe.md b/plugins/service-monitor-activemq/ReadMe.md
@@ -2,7 +2,7 @@ Activemq Service Monitor Plugin
 ====
 This module allows you to monitor Activemq service and status is show on Kylo UI under Service tab. Activemq URL is obtained from Kylo configuration file. 
 
-Pre-requisite : Make sure jms.activemq.broker.url is configured in application.properties.
+Pre-requisite : Make sure jms.activemq.broker.url is configured in kylo-services/conf/activemq.properties.
 
 To use this you need to do the following
 

diff --git a/...vemq/src/main/java/com/thinkbiganalytics/service/activemq/ActivemqServiceStatusCheck.java b/...vemq/src/main/java/com/thinkbiganalytics/service/activemq/ActivemqServiceStatusCheck.java
@@ -55,6 +55,7 @@ public class ActivemqServiceStatusCheck implements ServiceStatusCheck{
     public ActivemqServiceStatusCheck(String activemqBrokerUrl) {
 
         this.activemqBrokerUrl = activemqBrokerUrl;
+
         /**
          * Create Poolable Class Object and create multiple instance of connection 
          */
@@ -132,6 +133,10 @@ private ServiceComponent activemqStatus() {
         }
         finally
         {
+            /*
+             * Close Connection
+             */
+
             if(activemqConnection != null)
                 try {
                     activemqConnection.close();

diff --git a/.../java/com/thinkbiganalytics/service/activemq/util/ActivemqPoolableConnectionProvider.java b/.../java/com/thinkbiganalytics/service/activemq/util/ActivemqPoolableConnectionProvider.java
@@ -23,8 +23,6 @@
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.jms.pool.PooledConnectionFactory;
 
-import org.apache.log4j.Logger;
-
 import com.thinkbiganalytics.service.activemq.config.ActivemqTransportListner;
 
 public class ActivemqPoolableConnectionProvider {