Author: echatellier Date: 2010-09-27 09:49:11 +0200 (Mon, 27 Sep 2010) New Revision: 344 Url: http://nuiton.org/repositories/revision/wikitty/344 Log: Add more jgroups init log messages Modified: trunk/wikitty-api/src/main/java/org/nuiton/wikitty/JGroupsNotifier.java Modified: trunk/wikitty-api/src/main/java/org/nuiton/wikitty/JGroupsNotifier.java =================================================================== --- trunk/wikitty-api/src/main/java/org/nuiton/wikitty/JGroupsNotifier.java 2010-09-27 07:46:12 UTC (rev 343) +++ trunk/wikitty-api/src/main/java/org/nuiton/wikitty/JGroupsNotifier.java 2010-09-27 07:49:11 UTC (rev 344) @@ -109,16 +109,17 @@ channel.setReceiver(this); // don't receive messages sent by myself - channel.setOpt(Channel.LOCAL, false); + channel.setOpt(Channel.LOCAL, false); if (log.isInfoEnabled()) { - log.info("JGroup communication channel initialized to " + channel.getAddressAsString() + " (" + channel.getClusterName() + ")"); + log.info("JGroup communication channel initialized to " + + channel.getAddressAsString() + " (" + + channel.getClusterName() + ")"); log.info("Channel view: " + channel.getView()); } - } - catch (ChannelException eee) { + } catch (ChannelException eee) { if (log.isErrorEnabled()) { - log.error("Can't init jgroup channel"); + log.error("Can't init jgroup channel", eee); } } } @@ -132,6 +133,7 @@ if (log.isInfoEnabled()) { log.info("Send message : " + wikittyMessage); } + Message msg = new Message(null, null, wikittyMessage); try { channel.send(msg); @@ -151,9 +153,9 @@ */ @Override public void receive(Message msg) { - + Object message = msg.getObject(); - + if (log.isInfoEnabled()) { log.info("Receive message : " + msg.getObject()); } @@ -162,7 +164,7 @@ WikittyJGroupMessage wikittyMessage = (WikittyJGroupMessage)message; WikittyJGroupType type = wikittyMessage.type; WikittyServiceEvent event = wikittyMessage.event; - + //source is transient, add it here : event.setSource(ws); event.setRemote(true); // received event became remote @@ -195,8 +197,7 @@ public void putWikitty(WikittyServiceEvent event) { if (propagateCache) { sendJGroupMessage(new WikittyJGroupMessage(WikittyJGroupType.PUT_WIKITTY, event)); - } - else { + } else { if (log.isDebugEnabled()) { log.debug("Not master cache, do not propagate putWikitty event"); } @@ -210,8 +211,7 @@ public void removeWikitty(WikittyServiceEvent event) { if (propagateCache) { sendJGroupMessage(new WikittyJGroupMessage(WikittyJGroupType.REMOVE_WIKITTY, event)); - } - else { + } else { if (log.isDebugEnabled()) { log.debug("Not master cache, do not propagate removeWikitty event"); } @@ -225,8 +225,7 @@ public void clearWikitty(WikittyServiceEvent event) { if (propagateCache) { sendJGroupMessage(new WikittyJGroupMessage(WikittyJGroupType.CLEAR_WIKITTY, event)); - } - else { + } else { if (log.isDebugEnabled()) { log.debug("Not master cache, do not propagate clearWikitty event"); } @@ -240,8 +239,7 @@ public void putExtension(WikittyServiceEvent event) { if (propagateCache) { sendJGroupMessage(new WikittyJGroupMessage(WikittyJGroupType.PUT_EXTENSION, event)); - } - else { + } else { if (log.isDebugEnabled()) { log.debug("Not master cache, do not propagate putExtension event"); } @@ -255,8 +253,7 @@ public void removeExtension(WikittyServiceEvent event) { if (propagateCache) { sendJGroupMessage(new WikittyJGroupMessage(WikittyJGroupType.REMOVE_EXTENSION, event)); - } - else { + } else { if (log.isDebugEnabled()) { log.debug("Not master cache, do not propagate removeExtension event"); } @@ -270,8 +267,7 @@ public void clearExtension(WikittyServiceEvent event) { if (propagateCache) { sendJGroupMessage(new WikittyJGroupMessage(WikittyJGroupType.CLEAR_EXTENSION, event)); - } - else { + } else { if (log.isDebugEnabled()) { log.debug("Not master cache, do not propagate clearExtension event"); }