asmuts 02/01/14 22:22:46
Added: src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior
ILateralCacheAttributes.java
ILateralCacheListener.java
ILateralCacheObserver.java
ILateralCacheService.java
Log:
interfaces for lateral auxiliary caches
Revision Changes Path
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior/ILateralCacheAttributes.java
Index: ILateralCacheAttributes.java
===================================================================
package org.apache.stratum.jcs.auxiliary.lateral.behavior;
import java.io.*;
import java.util.*;
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.lateral.*;
import org.apache.stratum.jcs.auxiliary.lateral.http.broadcast.*;
import org.apache.stratum.jcs.auxiliary.lateral.http.remove.*;
import org.apache.stratum.jcs.utils.log.*;
import org.apache.stratum.jcs.utils.reuse.*;
///////////////////////////////////////////////////////////
public interface ILateralCacheAttributes extends Serializable,
IAuxiliaryCacheAttributes {
static final int HTTP = 1;
static final int UDP = 2;
static final int TCP = 3;
public void setHttpServer( String val );
public String getHttpServer();
///////////////////////////////////////
public void setTcpServer( String val );
public String getTcpServer();
/////////////////////////////////////
public void setTcpServers( String val );
public String getTcpServers();
/////////////////////////////////////////
public void setTcpListenerPort( int val );
public int getTcpListenerPort( );
// configure udp multicast parameters
public void setUdpMulticastAddr( String val );
public String getUdpMulticastAddr();
////////////////////////////////////////////
public void setUdpMulticastPort( int val );
public int getUdpMulticastPort( );
/////////////////////////////////////////
public void setTransmissionType( int val );
public int getTransmissionType( );
/////////////////////////////////////////
public void setTransmissionTypeName( String val );
public String getTransmissionTypeName();
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior/ILateralCacheListener.java
Index: ILateralCacheListener.java
===================================================================
package org.apache.stratum.jcs.auxiliary.lateral.behavior;
import org.apache.stratum.jcs.auxiliary.lateral.*;
import org.apache.stratum.jcs.engine.behavior.*;
/**
* Listens for lateral cache event notification.
*/
public interface ILateralCacheListener extends ICacheListener {
public void init();
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior/ILateralCacheObserver.java
Index: ILateralCacheObserver.java
===================================================================
package org.apache.stratum.jcs.auxiliary.lateral.behavior;
/**
* Title:
* Description:
* Copyright: Copyright (c) 2001
* Company:
* @author
* @version 1.0
*/
import org.apache.stratum.jcs.auxiliary.remote.*;
import org.apache.stratum.jcs.engine.behavior.*;
public interface ILateralCacheObserver extends ICacheObserver {
}
1.1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior/ILateralCacheService.java
Index: ILateralCacheService.java
===================================================================
package org.apache.stratum.jcs.auxiliary.lateral.behavior;
import org.apache.stratum.jcs.auxiliary.lateral.*;
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 lateral cache. */
public interface ILateralCacheService extends ICacheService {
/**
* Puts a cache item to the cache.
*/
public void update(ICacheElement item, byte requesterId) throws 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;
}
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>