cloud.orbit.actors.runtime

Class DefaultResponseCachingExtension

java.lang.Object

cloud.orbit.actors.net.HandlerAdapter

cloud.orbit.actors.runtime.DefaultResponseCachingExtension

All Implemented Interfaces:

ActorObserver, ExecutionCacheFlushObserver, ActorExtension, ResponseCachingExtension, Handler, Startable

public class DefaultResponseCachingExtension
extends HandlerAdapter
implements ResponseCachingExtension

Constructor Summary

Constructors

Constructor and Description
DefaultResponseCachingExtension()

Method Summary

Modifier and Type	Method and Description
Task<Void>	flush(Actor actor)
Task<Void>	flushWithoutWaiting(Actor actor)
Task<?>	get(Method method, Pair<Addressable,String> key) Retrieves a cached value for an actor's method.
Map<Method,Long>	getCacheSizes()
void	onActive(HandlerContext ctx)
void	put(Method method, Pair<Addressable,String> key, Task<?> value) Caches a value for an actor's method.
static void	setCacheExecutor(Executor cacheExecutor)
static void	setClock(Clock clock)
void	setMessageSerializer(MessageSerializer messageSerializer)
void	setObjectCloner(ExecutionObjectCloner objectCloner)
void	setRuntime(BasicRuntime runtime)
Task	write(HandlerContext ctx, Object msg)

Methods inherited from class cloud.orbit.actors.net.HandlerAdapter

close, connect, disconnect, onEventTriggered, onExceptionCaught, onInactive, onRead, onRegistered

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Methods inherited from interface cloud.orbit.actors.ActorObserver

getObserverReference, ping

Methods inherited from interface cloud.orbit.actors.net.Handler

close, connect, disconnect, onEventTriggered, onExceptionCaught, onInactive, onRead, onRegistered

Constructor Detail

DefaultResponseCachingExtension

public DefaultResponseCachingExtension()

Method Detail

setCacheExecutor

public static void setCacheExecutor(Executor cacheExecutor)

setClock

public static void setClock(Clock clock)

getCacheSizes

public Map<Method,Long> getCacheSizes()

get

public Task<?> get(Method method,
                   Pair<Addressable,String> key)

Retrieves a cached value for an actor's method. Returns null if there is no cached value.

Specified by:

get in interface ResponseCachingExtension

put

public void put(Method method,
                Pair<Addressable,String> key,
                Task<?> value)

Caches a value for an actor's method.

Specified by:

put in interface ResponseCachingExtension

flush

public Task<Void> flush(Actor actor)

Specified by:

flush in interface ExecutionCacheFlushObserver

setObjectCloner

public void setObjectCloner(ExecutionObjectCloner objectCloner)

flushWithoutWaiting

public Task<Void> flushWithoutWaiting(Actor actor)

Specified by:

flushWithoutWaiting in interface ExecutionCacheFlushObserver

write

public Task write(HandlerContext ctx,
                  Object msg)
           throws Exception

Specified by:

write in interface Handler

Overrides:

write in class HandlerAdapter

Throws:

Exception

onActive

public void onActive(HandlerContext ctx)
              throws Exception

Specified by:

onActive in interface Handler

Overrides:

onActive in class HandlerAdapter

Throws:

Exception

setMessageSerializer

public void setMessageSerializer(MessageSerializer messageSerializer)

setRuntime

public void setRuntime(BasicRuntime runtime)