asmuts 02/01/14 22:29:30
Added: src/java/org/apache/stratum/jcs/auxiliary/remote/behavior
IRemoteCacheAttributes.java
IRemoteCacheConstants.java
IRemoteCacheListener.java IRemoteCacheObserver.java
IRemoteCacheService.java
IRemoteCacheServiceAdmin.java
Log:
interfaces for the rmi based remote framework
Revision Changes Path
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/remote/behavior/IRemoteCacheAttributes.java
Index: IRemoteCacheAttributes.java
===================================================================
package org.apache.stratum.jcs.auxiliary.remote.behavior;
import org.apache.stratum.jcs.engine.behavior.ICacheAttributes;
import java.util.ArrayList;
import java.io.*;
import java.util.*;
//import org.apache.stratum.jcs.auxiliary.*;
import org.apache.stratum.jcs.auxiliary.behavior.*;
import org.apache.stratum.jcs.engine.*;
import org.apache.stratum.jcs.access.*;
import org.apache.stratum.jcs.engine.behavior.*;
import org.apache.stratum.jcs.access.exception.*;
import org.apache.stratum.jcs.auxiliary.remote.behavior.*;
import org.apache.stratum.jcs.auxiliary.remote.*;
import org.apache.stratum.jcs.utils.log.*;
import org.apache.stratum.jcs.utils.reuse.*;
public interface IRemoteCacheAttributes extends IAuxiliaryCacheAttributes {
/*
* A remote cache is either a local cache or a cluster cache.
*/
public static int LOCAL = 0;
public static int CLUSTER = 1;
////////////////////////////////////////////////////
public String getRemoteTypeName();
public void setRemoteTypeName( String s );
public int getRemoteType();
public void setRemoteType( int p );
// specifies which server in the list we are listening to
// if the number is greater than 0 we will try to move to 0 position
// the primary is added as position 1 if it is present
public int getFailoverIndex();
public void setFailoverIndex( int p );
public String[] getFailovers();
public void setFailovers( String[] f );
public String getRemoteServiceName();
public void setRemoteServiceName( String s );
public String getRemoteHost();
public void setRemoteHost( String s );
public int getRemotePort();
public void setRemotePort( int p );
public int getLocalPort();
public void setLocalPort( int p );
public String getClusterServers( );
public void setClusterServers( String s );
public String getFailoverServers( );
public void setFailoverServers( String s );
public boolean getRemoveUponRemotePut();
public void setRemoveUponRemotePut( boolean r );
public boolean getGetOnly();
public void setGetOnly( boolean r );
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/remote/behavior/IRemoteCacheConstants.java
Index: IRemoteCacheConstants.java
===================================================================
package org.apache.stratum.jcs.auxiliary.remote.behavior;
import org.apache.stratum.jcs.auxiliary.remote.behavior.IRemoteCacheService;
import org.apache.stratum.jcs.auxiliary.remote.*;
public interface IRemoteCacheConstants {
public static final String REMOTE_CACHE_SERVICE_NAME = "remote.cache.service.name";
public static final String REMOTE_CACHE_SERVICE_VAL =
IRemoteCacheService.class.getName();
public static final String JETTY_XML = "remote.jetty.xml";
public static final String JETTY_ON = "remote.jetty.on";
public static final String REMOTE_CACHE_SERVICE_PORT = "remote.cache.service.port";
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/remote/behavior/IRemoteCacheListener.java
Index: IRemoteCacheListener.java
===================================================================
package org.apache.stratum.jcs.auxiliary.remote.behavior;
import org.apache.stratum.jcs.auxiliary.remote.*;
import org.apache.stratum.jcs.engine.behavior.*;
import java.rmi.*;
import java.io.*;
/**
* Listens for remote cache event notification ( rmi callback ).
*/
public interface IRemoteCacheListener extends ICacheListener, Remote {
public static final int SERVER_LISTENER = 0;
public static final int CLIENT_LISTENER = 0;
public int getRemoteType() throws IOException;
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/remote/behavior/IRemoteCacheObserver.java
Index: IRemoteCacheObserver.java
===================================================================
package org.apache.stratum.jcs.auxiliary.remote.behavior;
import org.apache.stratum.jcs.auxiliary.remote.*;
import org.apache.stratum.jcs.engine.behavior.*;
import java.rmi.*;
/**
* Used to register interest in receiving remote cache changes.
*/
public interface IRemoteCacheObserver extends Remote, ICacheObserver {
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/remote/behavior/IRemoteCacheService.java
Index: IRemoteCacheService.java
===================================================================
package org.apache.stratum.jcs.auxiliary.remote.behavior;
import org.apache.stratum.jcs.auxiliary.remote.*;
import org.apache.stratum.jcs.engine.*;
import org.apache.stratum.jcs.engine.behavior.*;
import org.apache.stratum.jcs.access.exception.*;
import java.rmi.*;
import java.io.*;
/** Used to retrieve and update the remote cache. */
public interface IRemoteCacheService extends Remote, ICacheService {
/**
* Puts a cache item to the cache.
*/
public void update(ICacheElement item, byte requesterId) throws
ObjectExistsException, IOException;
/**
* Removes the given key from the specified cache.
*/
public void remove(String cacheName, Serializable key, byte requesterId) throws
IOException;
/**
* Remove all keys from the sepcified cache.
*/
public void removeAll(String cacheName, byte requesterId) throws IOException;
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/remote/behavior/IRemoteCacheServiceAdmin.java
Index: IRemoteCacheServiceAdmin.java
===================================================================
package org.apache.stratum.jcs.auxiliary.remote.behavior;
import org.apache.stratum.jcs.auxiliary.remote.*;
import org.apache.stratum.jcs.engine.behavior.*;
import java.rmi.*;
public interface IRemoteCacheServiceAdmin extends Remote, ICacheServiceAdmin {
}
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
