You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ni...@apache.org on 2014/12/04 04:07:36 UTC
stratos git commit: Catching interrupted exception issues when a
server shut down and logging an info.
Repository: stratos
Updated Branches:
refs/heads/master f26412893 -> 9b889d354
Catching interrupted exception issues when a server shut down and logging an info.
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/9b889d35
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/9b889d35
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/9b889d35
Branch: refs/heads/master
Commit: 9b889d354dd3e48359c8224811b68d63017a27f9
Parents: f264128
Author: Nirmal Fernando <ni...@gmail.com>
Authored: Thu Dec 4 08:38:49 2014 +0530
Committer: Nirmal Fernando <ni...@gmail.com>
Committed: Thu Dec 4 08:38:49 2014 +0530
----------------------------------------------------------------------
.../topology/TopologyEventMessageDelegator.java | 20 +++++++++-----------
1 file changed, 9 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/9b889d35/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageDelegator.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageDelegator.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageDelegator.java
index fc2b519..a1da2a8 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageDelegator.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyEventMessageDelegator.java
@@ -62,19 +62,17 @@ class TopologyEventMessageDelegator implements Runnable {
String json = message.getText();
if (log.isDebugEnabled()) {
- log.debug(String.format("Topology event message [%s] received from queue: %s", type, messageQueue.getClass()));
+ log.debug(String.format("Topology event message [%s] received from queue: %s", type,
+ messageQueue.getClass()));
}
-// try {
-// TopologyManager.acquireWriteLock();
- if (log.isDebugEnabled()) {
- log.debug(String.format("Delegating topology event message: %s", type));
- }
- processorChain.process(type, json, TopologyManager.getTopology());
-// } finally {
-// TopologyManager.releaseWriteLock();
-// }
-
+ if (log.isDebugEnabled()) {
+ log.debug(String.format("Delegating topology event message: %s", type));
+ }
+ processorChain.process(type, json, TopologyManager.getTopology());
+ } catch (InterruptedException e) {
+ log.info("TopologyEventMessageDelegator is shutting down ..");
+ return;
} catch (Exception e) {
log.error("Failed to retrieve topology event message", e);
}