You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2015/03/19 06:40:30 UTC
[3/6] stratos git commit: Format org.apache.stratos.messaging
component code according to coding standards
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageLoadAverageMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageLoadAverageMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageLoadAverageMessageProcessor.java
index 98fd204..c99c69c 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageLoadAverageMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageLoadAverageMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send average of Load average
+ * Processes event that is fired by Event processing engine to send average of Load average
*/
public class MemberAverageLoadAverageMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(MemberAverageLoadAverageMessageProcessor.class);
@@ -35,7 +35,7 @@ public class MemberAverageLoadAverageMessageProcessor extends MessageProcessor {
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class MemberAverageLoadAverageMessageProcessor extends MessageProcessor {
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageMemoryConsumptionMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageMemoryConsumptionMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageMemoryConsumptionMessageProcessor.java
index f33b79c..b79dee7 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageMemoryConsumptionMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberAverageMemoryConsumptionMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send average of memory consumption
+ * Processes event that is fired by Event processing engine to send average of memory consumption
*/
public class MemberAverageMemoryConsumptionMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(MemberAverageMemoryConsumptionMessageProcessor.class);
@@ -35,7 +35,7 @@ public class MemberAverageMemoryConsumptionMessageProcessor extends MessageProce
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class MemberAverageMemoryConsumptionMessageProcessor extends MessageProce
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberFaultMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberFaultMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberFaultMessageProcessor.java
index 950a69c..0ab9820 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberFaultMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberFaultMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send member fault event
+ * Processes event that is fired by Event processing engine to send member fault event
*/
public class MemberFaultMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(MemberFaultMessageProcessor.class);
@@ -35,7 +35,7 @@ public class MemberFaultMessageProcessor extends MessageProcessor {
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class MemberFaultMessageProcessor extends MessageProcessor {
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfLoadAverageMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfLoadAverageMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfLoadAverageMessageProcessor.java
index b84ca38..27b5b2d 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfLoadAverageMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfLoadAverageMessageProcessor.java
@@ -28,14 +28,14 @@ import org.apache.stratos.messaging.util.MessagingUtil;
/**
* Processes event that is fired by Event processing engine to send gradient of Load average
*/
-public class MemberGradientOfLoadAverageMessageProcessor extends MessageProcessor{
+public class MemberGradientOfLoadAverageMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(MemberGradientOfLoadAverageMessageProcessor.class);
private MessageProcessor nextProcessor;
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class MemberGradientOfLoadAverageMessageProcessor extends MessageProcesso
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfMemoryConsumptionMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfMemoryConsumptionMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfMemoryConsumptionMessageProcessor.java
index e17fa87..469caa5 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfMemoryConsumptionMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberGradientOfMemoryConsumptionMessageProcessor.java
@@ -36,7 +36,7 @@ public class MemberGradientOfMemoryConsumptionMessageProcessor extends MessagePr
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -50,16 +50,14 @@ public class MemberGradientOfMemoryConsumptionMessageProcessor extends MessagePr
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfLoadAverageMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfLoadAverageMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfLoadAverageMessageProcessor.java
index fb25388..73bebde 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfLoadAverageMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfLoadAverageMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send second derivative of Load average
+ * Processes event that is fired by Event processing engine to send second derivative of Load average
*/
public class MemberSecondDerivativeOfLoadAverageMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(MemberSecondDerivativeOfLoadAverageMessageProcessor.class);
@@ -35,7 +35,7 @@ public class MemberSecondDerivativeOfLoadAverageMessageProcessor extends Message
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class MemberSecondDerivativeOfLoadAverageMessageProcessor extends Message
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.java
index 66378d7..ffb6465 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send second derivative of memory consumption
+ * Processes event that is fired by Event processing engine to send second derivative of memory consumption
*/
public class MemberSecondDerivativeOfMemoryConsumptionMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(MemberSecondDerivativeOfMemoryConsumptionMessageProcessor.class);
@@ -35,7 +35,7 @@ public class MemberSecondDerivativeOfMemoryConsumptionMessageProcessor extends M
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class MemberSecondDerivativeOfMemoryConsumptionMessageProcessor extends M
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfLoadAverageMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfLoadAverageMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfLoadAverageMessageProcessor.java
index 304daa3..3197a1d 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfLoadAverageMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfLoadAverageMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send second derivative of Load average
+ * Processes event that is fired by Event processing engine to send second derivative of Load average
*/
public class SecondDerivativeOfLoadAverageMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(SecondDerivativeOfLoadAverageMessageProcessor.class);
@@ -35,7 +35,7 @@ public class SecondDerivativeOfLoadAverageMessageProcessor extends MessageProces
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class SecondDerivativeOfLoadAverageMessageProcessor extends MessageProces
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfMemoryConsumptionMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfMemoryConsumptionMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfMemoryConsumptionMessageProcessor.java
index 9a7fa22..dfbcf3a 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfMemoryConsumptionMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfMemoryConsumptionMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send second derivative of memory consumption
+ * Processes event that is fired by Event processing engine to send second derivative of memory consumption
*/
public class SecondDerivativeOfMemoryConsumptionMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(SecondDerivativeOfMemoryConsumptionMessageProcessor.class);
@@ -35,7 +35,7 @@ public class SecondDerivativeOfMemoryConsumptionMessageProcessor extends Message
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class SecondDerivativeOfMemoryConsumptionMessageProcessor extends Message
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfRequestsInFlightMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfRequestsInFlightMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfRequestsInFlightMessageProcessor.java
index b68892e..8a1b6fb 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfRequestsInFlightMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/health/stat/SecondDerivativeOfRequestsInFlightMessageProcessor.java
@@ -26,7 +26,7 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
/**
- * Processes event that is fired by Event processing engine to send second derivative of requests in flight
+ * Processes event that is fired by Event processing engine to send second derivative of requests in flight
*/
public class SecondDerivativeOfRequestsInFlightMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(SecondDerivativeOfRequestsInFlightMessageProcessor.class);
@@ -35,7 +35,7 @@ public class SecondDerivativeOfRequestsInFlightMessageProcessor extends MessageP
@Override
public void setNext(MessageProcessor nextProcessor) {
- this.nextProcessor = nextProcessor;
+ this.nextProcessor = nextProcessor;
}
@Override
@@ -49,16 +49,14 @@ public class SecondDerivativeOfRequestsInFlightMessageProcessor extends MessageP
// Notify event listeners
notifyEventListeners(event);
- if(log.isDebugEnabled()){
- log.debug(String.format("%s event processor notified listeners ... " , type));
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("%s event processor notified listeners ... ", type));
}
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process health stat message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/ArtifactUpdateMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/ArtifactUpdateMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/ArtifactUpdateMessageProcessor.java
index 1e18d68..5545cc5 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/ArtifactUpdateMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/ArtifactUpdateMessageProcessor.java
@@ -48,12 +48,10 @@ public class ArtifactUpdateMessageProcessor extends MessageProcessor {
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process artifact update message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupClusterNotifierMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupClusterNotifierMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupClusterNotifierMessageProcessor.java
index a14c070..13994ba 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupClusterNotifierMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupClusterNotifierMessageProcessor.java
@@ -25,9 +25,10 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
public class InstanceCleanupClusterNotifierMessageProcessor extends MessageProcessor {
- private static final Log log = LogFactory.getLog(InstanceCleanupClusterNotifierMessageProcessor.class);
+ private static final Log log = LogFactory.getLog(InstanceCleanupClusterNotifierMessageProcessor.class);
private MessageProcessor nextProcessor;
+
@Override
public void setNext(MessageProcessor nextProcessor) {
this.nextProcessor = nextProcessor;
@@ -43,12 +44,10 @@ public class InstanceCleanupClusterNotifierMessageProcessor extends MessageProce
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process instance clean up using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupMemberNotifierMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupMemberNotifierMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupMemberNotifierMessageProcessor.java
index 4776377..9ae015e 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupMemberNotifierMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceCleanupMemberNotifierMessageProcessor.java
@@ -25,9 +25,10 @@ import org.apache.stratos.messaging.message.processor.MessageProcessor;
import org.apache.stratos.messaging.util.MessagingUtil;
public class InstanceCleanupMemberNotifierMessageProcessor extends MessageProcessor {
- private static final Log log = LogFactory.getLog(InstanceCleanupMemberNotifierMessageProcessor.class);
+ private static final Log log = LogFactory.getLog(InstanceCleanupMemberNotifierMessageProcessor.class);
private MessageProcessor nextProcessor;
+
@Override
public void setNext(MessageProcessor nextProcessor) {
this.nextProcessor = nextProcessor;
@@ -42,12 +43,10 @@ public class InstanceCleanupMemberNotifierMessageProcessor extends MessageProces
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process instance clean up using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceNotifierMessageProcessorChain.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceNotifierMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceNotifierMessageProcessorChain.java
index 520cf0f..013a030 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceNotifierMessageProcessorChain.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/notifier/InstanceNotifierMessageProcessorChain.java
@@ -57,7 +57,7 @@ public class InstanceNotifierMessageProcessorChain extends MessageProcessorChain
artifactUpdateMessageProcessor.addEventListener(eventListener);
} else if (eventListener instanceof InstanceCleanupMemberEventListener) {
instanceCleanupMemberNotifierMessageProcessor.addEventListener(eventListener);
- } else if (eventListener instanceof InstanceCleanupClusterEventListener) {
+ } else if (eventListener instanceof InstanceCleanupClusterEventListener) {
instanceCleanupClusterNotifierMessageProcessor.addEventListener(eventListener);
} else {
throw new RuntimeException("Unknown event listener");
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberActivatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberActivatedMessageProcessor.java
index d055c69..452a25d 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberActivatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberActivatedMessageProcessor.java
@@ -42,7 +42,7 @@ public class InstanceStatusMemberActivatedMessageProcessor extends MessageProces
InstanceActivatedEvent event = (InstanceActivatedEvent) MessagingUtil.
jsonToObject(message, InstanceActivatedEvent.class);
- if(log.isDebugEnabled()) {
+ if (log.isDebugEnabled()) {
log.debug("Received ClusterStatusClusterActivatedEvent: " + event.toString());
}
// Notify event listeners
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberMaintenanceMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberMaintenanceMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberMaintenanceMessageProcessor.java
index 033d056..d0dee8b 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberMaintenanceMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberMaintenanceMessageProcessor.java
@@ -42,7 +42,7 @@ public class InstanceStatusMemberMaintenanceMessageProcessor extends MessageProc
InstanceMaintenanceModeEvent event = (InstanceMaintenanceModeEvent) MessagingUtil.
jsonToObject(message, InstanceMaintenanceModeEvent.class);
- if(log.isDebugEnabled()) {
+ if (log.isDebugEnabled()) {
log.debug("Received ClusterStatusClusterActivatedEvent: " + event.toString());
}
// Notify event listeners
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberReadyToShutdownMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberReadyToShutdownMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberReadyToShutdownMessageProcessor.java
index ccb9335..8ba6ea8 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberReadyToShutdownMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberReadyToShutdownMessageProcessor.java
@@ -40,9 +40,9 @@ public class InstanceStatusMemberReadyToShutdownMessageProcessor extends Message
if (InstanceReadyToShutdownEvent.class.getName().equals(type)) {
// Parse complete message and build event
InstanceReadyToShutdownEvent event = (InstanceReadyToShutdownEvent) MessagingUtil.
- jsonToObject(message, InstanceReadyToShutdownEvent.class);
+ jsonToObject(message, InstanceReadyToShutdownEvent.class);
- if(log.isDebugEnabled()) {
+ if (log.isDebugEnabled()) {
log.debug("Received ClusterStatusClusterInactivateEvent: " + event.toString());
}
// Notify event listeners
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberStartedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberStartedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberStartedMessageProcessor.java
index de25ab3..c24177a 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberStartedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMemberStartedMessageProcessor.java
@@ -40,9 +40,9 @@ public class InstanceStatusMemberStartedMessageProcessor extends MessageProcesso
if (InstanceStartedEvent.class.getName().equals(type)) {
// Parse complete message and build event
InstanceStartedEvent event = (InstanceStartedEvent) MessagingUtil.
- jsonToObject(message, InstanceStartedEvent.class);
+ jsonToObject(message, InstanceStartedEvent.class);
- if(log.isDebugEnabled()) {
+ if (log.isDebugEnabled()) {
log.debug("Received ClusterStatusClusterInactivateEvent: " + event.toString());
}
// Notify event listeners
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMessageProcessorChain.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMessageProcessorChain.java
index c425a7d..8b493b8 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMessageProcessorChain.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/instance/status/InstanceStatusMessageProcessorChain.java
@@ -71,9 +71,9 @@ public class InstanceStatusMessageProcessorChain extends MessageProcessorChain {
instanceStatusMemberStartedMessageProcessor.addEventListener(eventListener);
} else if (eventListener instanceof InstanceReadyToShutdownEventListener) {
instanceStatusMemberReadyToShutdownMessageProcessor.addEventListener(eventListener);
- } else if (eventListener instanceof InstanceMaintenanceListener) {
+ } else if (eventListener instanceof InstanceMaintenanceListener) {
instanceStatusMemberMaintenanceMessageProcessor.addEventListener(eventListener);
- } else if (eventListener instanceof InstanceActivatedEventListener) {
+ } else if (eventListener instanceof InstanceActivatedEventListener) {
instanceStatusMemberActivatedMessageProcessor.addEventListener(eventListener);
} else {
throw new RuntimeException("Unknown event listener");
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/CompleteTenantMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/CompleteTenantMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/CompleteTenantMessageProcessor.java
index e7366e4..d9a6822 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/CompleteTenantMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/CompleteTenantMessageProcessor.java
@@ -45,7 +45,7 @@ public class CompleteTenantMessageProcessor extends MessageProcessor {
public boolean process(String type, String message, Object object) {
if (CompleteTenantEvent.class.getName().equals(type)) {
// Return if tenant manager has already initialized
- if(TenantManager.getInstance().isInitialized()) {
+ if (TenantManager.getInstance().isInitialized()) {
return false;
}
@@ -55,7 +55,7 @@ public class CompleteTenantMessageProcessor extends MessageProcessor {
try {
TenantManager.acquireWriteLock();
TenantManager.getInstance().addTenants(event.getTenants());
- if(log.isInfoEnabled()) {
+ if (log.isInfoEnabled()) {
log.info("Tenant initialized");
}
TenantManager.getInstance().setInitialized(true);
@@ -63,16 +63,13 @@ public class CompleteTenantMessageProcessor extends MessageProcessor {
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- finally {
+ } finally {
TenantManager.releaseWriteLock();
}
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process tenant message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantCreatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantCreatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantCreatedMessageProcessor.java
index 7b1d1af..cfce926 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantCreatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantCreatedMessageProcessor.java
@@ -45,7 +45,7 @@ public class TenantCreatedMessageProcessor extends MessageProcessor {
public boolean process(String type, String message, Object object) {
if (TenantCreatedEvent.class.getName().equals(type)) {
// Return if tenant manager has not initialized
- if(!TenantManager.getInstance().isInitialized()) {
+ if (!TenantManager.getInstance().isInitialized()) {
return false;
}
@@ -55,23 +55,20 @@ public class TenantCreatedMessageProcessor extends MessageProcessor {
try {
TenantManager.acquireWriteLock();
TenantManager.getInstance().addTenant(event.getTenant());
- if(log.isInfoEnabled()) {
+ if (log.isInfoEnabled()) {
log.info(String.format("Tenant created: [tenant-id] %d [tenant-domain] %s", event.getTenant().getTenantId(), event.getTenant().getTenantDomain()));
}
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- finally {
+ } finally {
TenantManager.releaseWriteLock();
}
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process tenant message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java
index f1996f6..0382f4e 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantMessageProcessorChain.java
@@ -64,8 +64,7 @@ public class TenantMessageProcessorChain extends MessageProcessorChain {
tenantUpdatedMessageProcessor.addEventListener(eventListener);
} else if (eventListener instanceof TenantRemovedEventListener) {
tenantRemovedMessageProcessor.addEventListener(eventListener);
- }
- else {
+ } else {
throw new RuntimeException("Unknown event listener");
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantRemovedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantRemovedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantRemovedMessageProcessor.java
index aa67db0..56553d5 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantRemovedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantRemovedMessageProcessor.java
@@ -46,7 +46,7 @@ public class TenantRemovedMessageProcessor extends MessageProcessor {
public boolean process(String type, String message, Object object) {
if (TenantRemovedEvent.class.getName().equals(type)) {
// Return if tenant manager has not initialized
- if(!TenantManager.getInstance().isInitialized()) {
+ if (!TenantManager.getInstance().isInitialized()) {
return false;
}
@@ -56,14 +56,13 @@ public class TenantRemovedMessageProcessor extends MessageProcessor {
try {
TenantManager.acquireWriteLock();
Tenant tenant = TenantManager.getInstance().getTenant(event.getTenantId());
- if(tenant == null) {
- if(log.isWarnEnabled()) {
+ if (tenant == null) {
+ if (log.isWarnEnabled()) {
log.warn(String.format("Tenant already removed: [tenant-id] %d", event.getTenantId()));
}
- }
- else {
+ } else {
TenantManager.getInstance().removeTenant(event.getTenantId());
- if(log.isInfoEnabled()) {
+ if (log.isInfoEnabled()) {
log.info(String.format("Tenant removed: [tenant-id] %d [tenant-domain] %s", tenant.getTenantId(), tenant.getTenantDomain()));
}
}
@@ -71,16 +70,13 @@ public class TenantRemovedMessageProcessor extends MessageProcessor {
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- finally {
+ } finally {
TenantManager.releaseWriteLock();
}
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process tenant message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantUpdatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantUpdatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantUpdatedMessageProcessor.java
index 277039a..a2db0e7 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantUpdatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/tenant/TenantUpdatedMessageProcessor.java
@@ -46,7 +46,7 @@ public class TenantUpdatedMessageProcessor extends MessageProcessor {
public boolean process(String type, String message, Object object) {
if (TenantUpdatedEvent.class.getName().equals(type)) {
// Return if tenant manager has not initialized
- if(!TenantManager.getInstance().isInitialized()) {
+ if (!TenantManager.getInstance().isInitialized()) {
return false;
}
@@ -56,31 +56,28 @@ public class TenantUpdatedMessageProcessor extends MessageProcessor {
try {
TenantManager.acquireWriteLock();
Tenant tenant = TenantManager.getInstance().getTenant(event.getTenantId());
- if(tenant == null) {
- if(log.isWarnEnabled()) {
+ if (tenant == null) {
+ if (log.isWarnEnabled()) {
log.warn(String.format("Tenant not found: [tenant-id] %d", event.getTenantId()));
}
return false;
}
tenant.setTenantDomain(event.getTenantDomain());
- if(log.isInfoEnabled()) {
+ if (log.isInfoEnabled()) {
log.info(String.format("Tenant updated: [tenant-id] %d [tenant-domain] %s", tenant.getTenantId(), tenant.getTenantDomain()));
}
// Notify event listeners
notifyEventListeners(event);
return true;
- }
- finally {
+ } finally {
TenantManager.releaseWriteLock();
}
- }
- else {
- if(nextProcessor != null) {
+ } else {
+ if (nextProcessor != null) {
return nextProcessor.process(type, message, object);
- }
- else {
+ } else {
throw new RuntimeException(String.format("Failed to process tenant message using available message processors: [type] %s [body] %s", type, message));
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersCreatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersCreatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersCreatedMessageProcessor.java
index 0b042a3..0e90a35 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersCreatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersCreatedMessageProcessor.java
@@ -38,6 +38,7 @@ import java.util.List;
public class ApplicationClustersCreatedMessageProcessor extends MessageProcessor {
private static final Log log = LogFactory.getLog(ApplicationClustersCreatedMessageProcessor.class);
private MessageProcessor nextProcessor;
+
@Override
public void setNext(MessageProcessor nextProcessor) {
this.nextProcessor = nextProcessor;
@@ -54,8 +55,8 @@ public class ApplicationClustersCreatedMessageProcessor extends MessageProcessor
// Parse complete message and build event
ApplicationClustersCreatedEvent event = (ApplicationClustersCreatedEvent) MessagingUtil.
- jsonToObject(message, ApplicationClustersCreatedEvent.class);
- return doProcess(event, topology);
+ jsonToObject(message, ApplicationClustersCreatedEvent.class);
+ return doProcess(event, topology);
} else {
@@ -68,22 +69,22 @@ public class ApplicationClustersCreatedMessageProcessor extends MessageProcessor
}
}
- private boolean doProcess (ApplicationClustersCreatedEvent event,Topology topology) {
+ private boolean doProcess(ApplicationClustersCreatedEvent event, Topology topology) {
List<Cluster> clusters = event.getClusterList();
- for(Cluster cluster : clusters) {
+ for (Cluster cluster : clusters) {
String serviceName = cluster.getServiceName();
String clusterId = cluster.getClusterId();
TopologyUpdater.acquireWriteLockForService(serviceName);
try {
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
continue;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
continue;
}
@@ -99,7 +100,7 @@ public class ApplicationClustersCreatedMessageProcessor extends MessageProcessor
if (service.clusterExists(clusterId)) {
if (log.isDebugEnabled()) {
log.debug(String.format("Cluster already exists in service: [service] %s " +
- "[cluster] %s",serviceName ,
+ "[cluster] %s", serviceName,
clusterId));
}
} else {
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersRemovedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersRemovedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersRemovedMessageProcessor.java
index 2bac8da..fa81fd9 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersRemovedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ApplicationClustersRemovedMessageProcessor.java
@@ -67,7 +67,7 @@ public class ApplicationClustersRemovedMessageProcessor extends MessageProcessor
}
}
- private boolean doProcess (ApplicationClustersRemovedEvent event,Topology topology) {
+ private boolean doProcess(ApplicationClustersRemovedEvent event, Topology topology) {
Set<ClusterDataHolder> clusterData = event.getClusterData();
if (clusterData != null) {
@@ -96,7 +96,7 @@ public class ApplicationClustersRemovedMessageProcessor extends MessageProcessor
}
} else {
- if(log.isDebugEnabled()) {
+ if (log.isDebugEnabled()) {
log.debug("No cluster data found in application " + event.getAppId() + " to remove from Topology");
}
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterCreatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterCreatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterCreatedMessageProcessor.java
index 52e3492..8a083cc 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterCreatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterCreatedMessageProcessor.java
@@ -69,18 +69,18 @@ public class ClusterCreatedMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess (ClusterCreatedEvent event,Topology topology) {
+ private boolean doProcess(ClusterCreatedEvent event, Topology topology) {
Cluster cluster = event.getCluster();
String serviceName = cluster.getServiceName();
String clusterId = cluster.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -96,7 +96,7 @@ public class ClusterCreatedMessageProcessor extends MessageProcessor {
if (service.clusterExists(clusterId)) {
if (log.isDebugEnabled()) {
log.debug(String.format("Cluster already exists in service: [service] %s " +
- "[cluster] %s",serviceName ,
+ "[cluster] %s", serviceName,
clusterId));
}
} else {
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java
index c716990..7c3e04e 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceActivatedProcessor.java
@@ -83,12 +83,12 @@ public class ClusterInstanceActivatedProcessor extends MessageProcessor {
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -112,13 +112,13 @@ public class ClusterInstanceActivatedProcessor extends MessageProcessor {
} else {
// Apply changes to the topology
List<KubernetesService> kubernetesServices = event.getKubernetesServices();
- if(kubernetesServices != null) {
+ if (kubernetesServices != null) {
// Set kubernetes services
cluster.setKubernetesServices(kubernetesServices);
}
ClusterInstance context = cluster.getInstanceContexts(event.getInstanceId());
- if(context == null) {
+ if (context == null) {
log.warn("Cluster instance context is not found for [cluster] " +
event.getClusterId() + " [instance-id] " +
event.getInstanceId());
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceCreatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceCreatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceCreatedMessageProcessor.java
index 2f1485f..d7e4606 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceCreatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceCreatedMessageProcessor.java
@@ -73,18 +73,18 @@ public class ClusterInstanceCreatedMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess (ClusterInstanceCreatedEvent event,Topology topology) {
+ private boolean doProcess(ClusterInstanceCreatedEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -108,7 +108,7 @@ public class ClusterInstanceCreatedMessageProcessor extends MessageProcessor {
} else {
// Apply changes to the topology
ClusterInstance clusterInstance = event.getClusterInstance();
- if(cluster.getInstanceContexts(clusterInstance.getInstanceId()) != null) {
+ if (cluster.getInstanceContexts(clusterInstance.getInstanceId()) != null) {
if (log.isDebugEnabled()) {
log.debug(String.format("Cluster Instance already exists in service: " +
"[service] %s [cluster] %s [Instance] %s", event.getServiceName(),
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceInactivateProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceInactivateProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceInactivateProcessor.java
index 0de185f..319d71b 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceInactivateProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceInactivateProcessor.java
@@ -83,12 +83,12 @@ public class ClusterInstanceInactivateProcessor extends MessageProcessor {
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -111,7 +111,7 @@ public class ClusterInstanceInactivateProcessor extends MessageProcessor {
} else {
// Apply changes to the topology
ClusterInstance context = cluster.getInstanceContexts(event.getInstanceId());
- if(context == null) {
+ if (context == null) {
log.warn("Cluster Instance Context is not found for [cluster] " +
event.getClusterId() + " [instance-id] " +
event.getInstanceId());
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatedProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatedProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatedProcessor.java
index 45a3578..3a56440 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatedProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatedProcessor.java
@@ -83,12 +83,12 @@ public class ClusterInstanceTerminatedProcessor extends MessageProcessor {
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -112,8 +112,8 @@ public class ClusterInstanceTerminatedProcessor extends MessageProcessor {
} else {
// Apply changes to the topology
ClusterInstance context = cluster.getInstanceContexts(event.getInstanceId());
- if(context == null) {
- if(log.isDebugEnabled()) {
+ if (context == null) {
+ if (log.isDebugEnabled()) {
log.warn("Cluster Instance Context is already removed for [cluster] " +
event.getClusterId() + " [instance-id] " +
event.getInstanceId());
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatingProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatingProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatingProcessor.java
index f058def..0058dff 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatingProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterInstanceTerminatingProcessor.java
@@ -83,12 +83,12 @@ public class ClusterInstanceTerminatingProcessor extends MessageProcessor {
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -111,7 +111,7 @@ public class ClusterInstanceTerminatingProcessor extends MessageProcessor {
} else {
// Apply changes to the topology
ClusterInstance context = cluster.getInstanceContexts(event.getInstanceId());
- if(context == null) {
+ if (context == null) {
log.warn("Cluster Instance Context is not found for [cluster] " +
event.getClusterId() + " [instance-id] " +
event.getInstanceId());
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterRemovedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterRemovedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterRemovedMessageProcessor.java
index 2dda37e..361c6d2 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterRemovedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterRemovedMessageProcessor.java
@@ -69,18 +69,18 @@ public class ClusterRemovedMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess (ClusterRemovedEvent event,Topology topology) {
+ private boolean doProcess(ClusterRemovedEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterResetMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterResetMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterResetMessageProcessor.java
index 235eafc..1168776 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterResetMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/ClusterResetMessageProcessor.java
@@ -74,18 +74,18 @@ public class ClusterResetMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess (ClusterResetEvent event,Topology topology) {
+ private boolean doProcess(ClusterResetEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -108,7 +108,7 @@ public class ClusterResetMessageProcessor extends MessageProcessor {
} else {
// Apply changes to the topology
ClusterInstance context = cluster.getInstanceContexts(event.getInstanceId());
- if(context == null) {
+ if (context == null) {
log.warn("Cluster Instance Context is not found for [cluster] " +
event.getClusterId() + " [instance-id] " +
event.getInstanceId());
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java
index ed30488..fd69522 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java
@@ -50,8 +50,8 @@ public class CompleteTopologyMessageProcessor extends MessageProcessor {
Topology topology = (Topology) object;
if (CompleteTopologyEvent.class.getName().equals(type)) {
- // Parse complete message and build event
- CompleteTopologyEvent event = (CompleteTopologyEvent) MessagingUtil.jsonToObject(message, CompleteTopologyEvent.class);
+ // Parse complete message and build event
+ CompleteTopologyEvent event = (CompleteTopologyEvent) MessagingUtil.jsonToObject(message, CompleteTopologyEvent.class);
if (!topology.isInitialized()) {
TopologyUpdater.acquireWriteLock();
@@ -77,11 +77,11 @@ public class CompleteTopologyMessageProcessor extends MessageProcessor {
}
}
- private void doProcess (CompleteTopologyEvent event, Topology topology) {
+ private void doProcess(CompleteTopologyEvent event, Topology topology) {
for (Service service : event.getTopology().getServices()) {
// Apply service filter
- if(TopologyServiceFilter.apply(service.getServiceName())) {
+ if (TopologyServiceFilter.apply(service.getServiceName())) {
continue;
}
// Add service
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberActivatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberActivatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberActivatedMessageProcessor.java
index 82e4619..cb83343 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberActivatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberActivatedMessageProcessor.java
@@ -73,18 +73,18 @@ public class MemberActivatedMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess (MemberActivatedEvent event,Topology topology) {
+ private boolean doProcess(MemberActivatedEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -130,7 +130,7 @@ public class MemberActivatedMessageProcessor extends MessageProcessor {
}
// Apply member filter
- if(TopologyMemberFilter.apply(member.getLbClusterId(), member.getNetworkPartitionId())) {
+ if (TopologyMemberFilter.apply(member.getLbClusterId(), member.getNetworkPartitionId())) {
return false;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberCreatedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberCreatedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberCreatedMessageProcessor.java
index c4e1f31..3669e6c 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberCreatedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberCreatedMessageProcessor.java
@@ -71,18 +71,18 @@ public class MemberCreatedMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess (MemberCreatedEvent event,Topology topology){
+ private boolean doProcess(MemberCreatedEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberInitializedMessageProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberInitializedMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberInitializedMessageProcessor.java
index b8f0b15..bf3bb97 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberInitializedMessageProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberInitializedMessageProcessor.java
@@ -67,18 +67,18 @@ public class MemberInitializedMessageProcessor extends MessageProcessor {
}
}
- private boolean doProcess(MemberInitializedEvent event,Topology topology) {
+ private boolean doProcess(MemberInitializedEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -111,7 +111,7 @@ public class MemberInitializedMessageProcessor extends MessageProcessor {
}
// Apply member filter
- if(TopologyMemberFilter.apply(member.getLbClusterId(), member.getNetworkPartitionId())) {
+ if (TopologyMemberFilter.apply(member.getLbClusterId(), member.getNetworkPartitionId())) {
return false;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/b7df7ea8/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberMaintenanceModeProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberMaintenanceModeProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberMaintenanceModeProcessor.java
index a999f4e..b0f13b5 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberMaintenanceModeProcessor.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/MemberMaintenanceModeProcessor.java
@@ -50,7 +50,7 @@ public class MemberMaintenanceModeProcessor extends MessageProcessor {
// Parse complete message and build event
MemberMaintenanceModeEvent event = (MemberMaintenanceModeEvent) MessagingUtil.
- jsonToObject(message, MemberMaintenanceModeEvent.class);
+ jsonToObject(message, MemberMaintenanceModeEvent.class);
TopologyUpdater.acquireWriteLockForCluster(event.getServiceName(), event.getClusterId());
try {
@@ -70,18 +70,18 @@ public class MemberMaintenanceModeProcessor extends MessageProcessor {
}
}
- private boolean doProcess (MemberMaintenanceModeEvent event,Topology topology) {
+ private boolean doProcess(MemberMaintenanceModeEvent event, Topology topology) {
String serviceName = event.getServiceName();
String clusterId = event.getClusterId();
// Apply service filter
- if(TopologyServiceFilter.apply(serviceName)) {
+ if (TopologyServiceFilter.apply(serviceName)) {
return false;
}
// Apply cluster filter
- if(TopologyClusterFilter.apply(clusterId)) {
+ if (TopologyClusterFilter.apply(clusterId)) {
return false;
}
@@ -114,14 +114,14 @@ public class MemberMaintenanceModeProcessor extends MessageProcessor {
}
// Apply member filter
- if(TopologyMemberFilter.apply(member.getLbClusterId(), member.getNetworkPartitionId())) {
+ if (TopologyMemberFilter.apply(member.getLbClusterId(), member.getNetworkPartitionId())) {
return false;
}
if (member.getStatus() == MemberStatus.In_Maintenance) {
if (log.isDebugEnabled()) {
log.debug(String.format("Member already updated as In_Maintenance: " +
- "[service] %s [cluster] %s [member] %s",
+ "[service] %s [cluster] %s [member] %s",
event.getServiceName(),
event.getClusterId(),
event.getMemberId()));