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]
