You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jcs-dev@jakarta.apache.org by as...@apache.org on 2004/05/11 03:04:59 UTC

cvs commit: jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral LateralCacheManager.java

asmuts      2004/05/10 18:04:59

  Modified:    src/java/org/apache/jcs/auxiliary/lateral
                        LateralCacheManager.java
  Log:
  Adding javagroups back to the main source tree after lots of testing.  It is the only useful solution for distribution across multiple vms on the same machine.  it is also useful when you don't know how many instances of you applicaiton might be created.
  
  Revision  Changes    Path
  1.8       +14 -0     jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheManager.java
  
  Index: LateralCacheManager.java
  ===================================================================
  RCS file: /home/cvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheManager.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -r1.7 -r1.8
  --- LateralCacheManager.java	15 Apr 2004 19:22:48 -0000	1.7
  +++ LateralCacheManager.java	11 May 2004 01:04:59 -0000	1.8
  @@ -33,6 +33,9 @@
   import org.apache.jcs.auxiliary.lateral.behavior.ILateralCacheService;
   import org.apache.jcs.auxiliary.lateral.socket.tcp.LateralTCPService;
   import org.apache.jcs.auxiliary.lateral.socket.tcp.LateralTCPListener;
  +import org.apache.jcs.auxiliary.lateral.javagroups.LateralJGService;
  +import org.apache.jcs.auxiliary.lateral.javagroups.LateralCacheJGListener;
  +
   
   /**
    * Creates lateral caches. Lateral caches are primarily used for removing non
  @@ -137,6 +140,13 @@
   
                   this.lateralService = new LateralTCPService( lca );
               }
  +            else if ( lca.getTransmissionType() == lca.JAVAGROUPS )
  +            {
  +                log.debug( "Creating JAVAGROUPS service" );
  +
  +                this.lateralService = new LateralJGService( lca );
  +            }
  +
               else
               {
                   log.error( "Type not recognized, must zombie" );
  @@ -218,6 +228,10 @@
               if ( lca.getTransmissionType() == lca.TCP )
               {
                   addLateralCacheListener( cacheName, LateralTCPListener.getInstance( lca ) );
  +            }
  +            else if ( lca.getTransmissionType() == lca.JAVAGROUPS )
  +            {
  +                addLateralCacheListener( cacheName, LateralCacheJGListener.getInstance( lca ) );
               }
           }
           catch ( IOException ioe )
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: turbine-jcs-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: turbine-jcs-dev-help@jakarta.apache.org