deleting some commented out methods

apache · Dec 24, 2015 · 63f931f · 63f931f
1 parent 617258b
commit 63f931f
Show file tree

Hide file tree

Showing 10 changed files with 1 addition and 81 deletions.
diff --git a/.../org/apache/stratos/messaging/message/receiver/application/ApplicationsEventReceiver.java b/.../org/apache/stratos/messaging/message/receiver/application/ApplicationsEventReceiver.java
@@ -29,8 +29,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
-
 public class ApplicationsEventReceiver extends StratosEventReceiver{
  private static final Log log = LogFactory.getLog(ApplicationsEventReceiver.class);
 
@@ -117,12 +115,4 @@ public void run() {
  }
  });
  }
-
-// public ExecutorService getExecutorService() {
-// return executorService;
-// }
-//
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
 }
diff --git a/...stratos/messaging/message/receiver/application/signup/ApplicationSignUpEventReceiver.java b/...stratos/messaging/message/receiver/application/signup/ApplicationSignUpEventReceiver.java
@@ -30,8 +30,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
-
 /**
  * Application signup event receiver.
  */
@@ -119,12 +117,4 @@ public void terminate() {
  eventSubscriber.terminate();
  messageDelegator.terminate();
  }
-
-// public ExecutorService getExecutorService() {
-// return executorService;
-// }
-
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
 }
diff --git a/.../apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventReceiver.java b/.../apache/stratos/messaging/message/receiver/cluster/status/ClusterStatusEventReceiver.java
@@ -27,7 +27,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
 
 /**
  * A thread for receiving instance notifier information from message broker.
@@ -91,18 +90,4 @@ private void execute() {
  public boolean isSubscribed() {
  return ((eventSubscriber != null) && (eventSubscriber.isSubscribed()));
  }
-
-// public void terminate() {
-// eventSubscriber.terminate();
-// messageDelegator.terminate();
-// terminated = true;
-// }
-//
-// public ExecutorService getExecutorService() {
-// return executorService;
-// }
-//
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
 }
diff --git a/.../apache/stratos/messaging/message/receiver/domain/mapping/DomainMappingEventReceiver.java b/.../apache/stratos/messaging/message/receiver/domain/mapping/DomainMappingEventReceiver.java
@@ -27,8 +27,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
-
 /**
  * Domain mapping event receiver.
  */

diff --git a/...va/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java b/...va/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java
@@ -27,8 +27,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
-
 /**
  * A thread for receiving health stat information from message broker
  */
@@ -84,18 +82,4 @@ private void execute() {
  }
  }
  }
-
-// public void terminate() {
-// eventSubscriber.terminate();
-// messageDelegator.terminate();
-// terminated = true;
-// }
-//
-// public ExecutorService getExecutorService() {
-// return executorService;
-// }
-//
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
 }
diff --git a/...a/org/apache/stratos/messaging/message/receiver/initializer/InitializerEventReceiver.java b/...a/org/apache/stratos/messaging/message/receiver/initializer/InitializerEventReceiver.java
@@ -85,12 +85,4 @@ public void terminate() {
  eventSubscriber.terminate();
  messageDelegator.terminate();
  }
-
-// public ExecutorService getExecutorService() {
-// return executorService;
-// }
-//
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
 }
diff --git a/...e/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventReceiver.java b/...e/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventReceiver.java
@@ -43,10 +43,7 @@ private InstanceNotifierEventReceiver() {
  this.executorService = StratosThreadPool.getExecutorService("topology-event-receiver", 100);
  InstanceNotifierEventMessageQueue messageQueue = new InstanceNotifierEventMessageQueue();
  this.messageDelegator = new InstanceNotifierEventMessageDelegator(messageQueue);
- messageListener = new InstanceNotifierEventMessageListener(messageQueue);
- // Start topic subscriber thread
- eventSubscriber = new EventSubscriber(MessagingUtil.Topics.INSTANCE_NOTIFIER_TOPIC.getTopicName(),
- messageListener);
+ this.messageListener = new InstanceNotifierEventMessageListener(messageQueue);
  execute();
  }
 

diff --git a/...pache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventReceiver.java b/...pache/stratos/messaging/message/receiver/instance/status/InstanceStatusEventReceiver.java
@@ -93,12 +93,4 @@ public void terminate() {
  messageDelegator.terminate();
  // terminated = true;
  }
-
-// public ExecutorService getExecutorService() {
-// return executorService;
-// }
-//
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
 }
diff --git a/...c/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventReceiver.java b/...c/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantEventReceiver.java
@@ -30,8 +30,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
-
 /**
  * A thread for receiving tenant information from message broker and
  * build tenant information in tenant manager.
@@ -68,10 +66,6 @@ public void addEventListener(EventListener eventListener) {
  messageDelegator.addEventListener(eventListener);
  }
 
-// public void setExecutorService(ExecutorService executorService) {
-// this.executorService = executorService;
-// }
-
  private void execute() {
  try {
  // Start topic subscriber thread

diff --git a/...in/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java b/...in/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventReceiver.java
@@ -30,8 +30,6 @@
 import org.apache.stratos.messaging.message.receiver.StratosEventReceiver;
 import org.apache.stratos.messaging.util.MessagingUtil;
 
-import java.util.concurrent.ExecutorService;
-
 /**
  * A thread for receiving topology information from message broker and
  * build topology in topology manager.