fhanik 2003/10/14 14:53:28 Modified: modules/cluster/src/share/org/apache/catalina/cluster/session SimpleTcpReplicationManager.java Log: now respecting the distributable flag Revision Changes Path 1.11 +14 -4 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/session/SimpleTcpReplicationManager.java Index: SimpleTcpReplicationManager.java =================================================================== RCS file: /home/cvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/session/SimpleTcpReplicationManager.java,v retrieving revision 1.10 retrieving revision 1.11 diff -u -r1.10 -r1.11 --- SimpleTcpReplicationManager.java 9 Sep 2003 22:21:18 -0000 1.10 +++ SimpleTcpReplicationManager.java 14 Oct 2003 21:53:28 -0000 1.11 @@ -281,7 +281,7 @@ public Session createSession() { //create a session and notify the other nodes in the cluster - Session session = createSession(distributable,true); + Session session = createSession(getDistributable(),true); add(session); return session; } @@ -303,6 +303,11 @@ public SessionMessage requestCompleted(String sessionId) { + if ( !getDistributable() ) { + log.warn("Received requestCompleted message, although this context["+ + getName()+"] is not distributable. Ignoring message"); + return null; + } //notify javagroups try { @@ -523,6 +528,11 @@ try { log("Received SessionMessage of type="+msg.getEventTypeString(),3); log("Received SessionMessage sender="+sender,3); + if ( !this.getDistributable() ) { + log.warn("Received replication message, although this context["+ + getName()+"] is not distributable. Ignoring message"); + return; + } switch ( msg.getEventType() ) { case SessionMessage.EVT_GET_ALL_SESSIONS: { //get a list of all the session from this manager
--------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]