fhanik 2003/11/14 17:07:23
Modified: modules/cluster/src/share/org/apache/catalina/cluster/session
SimpleTcpReplicationManager.java
modules/cluster/src/share/org/apache/catalina/cluster/tcp
SimpleTcpCluster.java
Log:
a little more refactoring
Revision Changes Path
1.16 +4 -3
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.15
retrieving revision 1.16
diff -u -r1.15 -r1.16
--- SimpleTcpReplicationManager.java 15 Nov 2003 00:58:20 -0000 1.15
+++ SimpleTcpReplicationManager.java 15 Nov 2003 01:07:23 -0000 1.16
@@ -110,6 +110,7 @@
* a byte array using the StandardSession.readObjectData,
StandardSession.writeObjectData methods.
*/
public class SimpleTcpReplicationManager extends
org.apache.catalina.session.StandardManager
+implements org.apache.catalina.cluster.ClusterManager
{
//the channel configuration
1.18 +7 -7
jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/SimpleTcpCluster.java
Index: SimpleTcpCluster.java
===================================================================
RCS file:
/home/cvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/SimpleTcpCluster.java,v
retrieving revision 1.17
retrieving revision 1.18
diff -u -r1.17 -r1.18
--- SimpleTcpCluster.java 15 Nov 2003 00:58:20 -0000 1.17
+++ SimpleTcpCluster.java 15 Nov 2003 01:07:23 -0000 1.18
@@ -96,6 +96,7 @@
import org.apache.catalina.cluster.SessionMessage;
import org.apache.catalina.cluster.session.ReplicationStream;
+import org.apache.catalina.cluster.ClusterManager;
import org.apache.catalina.cluster.session.SimpleTcpReplicationManager;
import org.apache.catalina.cluster.Constants;
@@ -670,15 +671,14 @@
java.util.Iterator i = managers.keySet().iterator();
while ( i.hasNext() ) {
String key = (String)i.next();
- SimpleTcpReplicationManager mgr =
(SimpleTcpReplicationManager) managers.get(key);
+ ClusterManager mgr = (ClusterManager) managers.get(key);
if (mgr != null)
mgr.messageDataReceived(msg);
else
log.warn("Context manager doesn't exist:" + key);
}//while
} else {
- SimpleTcpReplicationManager mgr = (
- SimpleTcpReplicationManager) managers.get(name);
+ ClusterManager mgr = (ClusterManager) managers.get(name);
if (mgr != null)
mgr.messageDataReceived(msg);
else
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
