diff --git a/src/org/jgroups/blocks/MessageDispatcher.java b/src/org/jgroups/blocks/MessageDispatcher.java index 05042e4b54d..c5aa057465b 100644 --- a/src/org/jgroups/blocks/MessageDispatcher.java +++ b/src/org/jgroups/blocks/MessageDispatcher.java @@ -1,4 +1,4 @@ -// $Id: MessageDispatcher.java,v 1.29 2004/08/05 07:55:07 belaban Exp $ +// $Id: MessageDispatcher.java,v 1.30 2004/09/02 14:00:40 belaban Exp $ package org.jgroups.blocks; @@ -243,7 +243,8 @@ private void setMembers(Vector new_mbrs) { public void setDeadlockDetection(boolean flag) { deadlock_detection=flag; - corr.setDeadlockDetection(flag); + if(corr != null) + corr.setDeadlockDetection(flag); } public void setConcurrentProcessing(boolean flag) { @@ -635,10 +636,10 @@ public void passUp(Event evt) { membership_listener.viewAccepted(v); } break; -// -// case Event.SET_LOCAL_ADDRESS: -// local_addr=(Address)evt.getArg(); -// break; + + case Event.SET_LOCAL_ADDRESS: + local_addr=(Address)evt.getArg(); + break; case Event.SUSPECT: if(membership_listener != null) { @@ -717,7 +718,7 @@ public void up(Event evt) { } private void handleUp(Event evt) { - if(null != corr) { + if(corr != null) { corr.receive(evt); } else {