cloud.orbit.actors

Class Stage.Builder

java.lang.Object

cloud.orbit.actors.Stage.Builder

Enclosing class:

Stage

public static class Stage.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
Stage.Builder	actorTTL(long duration, TimeUnit timeUnit)
Stage.Builder	basePackages(Collection<String> basePackages)
Stage.Builder	basePackages(String... basePackages)
Stage.Builder	broadcastActorDeactivations(boolean broadcastActorDeactivations)
Stage	build()
Stage.Builder	clock(Clock clock)
Stage.Builder	clusterName(String clusterName)
Stage.Builder	clusterPeer(ClusterPeer clusterPeer)
Stage.Builder	concurrentDeactivations(int concurrentDeactivations)
Stage.Builder	deactivationTimeout(long duration, TimeUnit timeUnit)
Stage.Builder	enableMessageLoopback(Boolean enableMessageLoopback)
Stage.Builder	enableShutdownHook(boolean enableShutdownHook)
Stage.Builder	execution(Execution execution)
Stage.Builder	executionPool(ExecutorService executionPool)
Stage.Builder	executionPoolSize(int executionPoolSize)
Stage.Builder	extensions(ActorExtension... extensions)
Stage.Builder	extensions(Collection<ActorExtension> extensions)
Stage.Builder	flushPlacementGroupCache(boolean flushPlacementGroupCache)
Stage.Builder	invocationHandler(InvocationHandler invocationHandler)
Stage.Builder	localAddressCacheMaximumSize(int localAddressCacheMaximumSize)
Stage.Builder	localAddressCacheTTL(long duration, TimeUnit timeUnit)
Stage.Builder	localObjectsCleaner(LocalObjectsCleaner localObjectsCleaner)
Stage.Builder	messageLoopbackObjectCloner(ExecutionObjectCloner messageLoopbackObjectCloner)
Stage.Builder	messageSerializer(MessageSerializer messageSerializer)
Stage.Builder	messaging(Messaging messaging)
Stage.Builder	mode(Stage.StageMode mode)
Stage.Builder	nodeName(String nodeName)
Stage.Builder	numReminderControllers(int numReminderControllers)
Stage.Builder	objectCloner(ExecutionObjectCloner objectCloner)
Stage.Builder	placementGroup(String placementGroup)
Stage.Builder	stickyHeaders(String... stickyHeaders)
Stage.Builder	timer(Timer timer)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

clock

public Stage.Builder clock(Clock clock)

enableMessageLoopback

public Stage.Builder enableMessageLoopback(Boolean enableMessageLoopback)

executionPool

public Stage.Builder executionPool(ExecutorService executionPool)

executionPoolSize

public Stage.Builder executionPoolSize(int executionPoolSize)

localAddressCacheMaximumSize

public Stage.Builder localAddressCacheMaximumSize(int localAddressCacheMaximumSize)

execution

public Stage.Builder execution(Execution execution)

localObjectsCleaner

public Stage.Builder localObjectsCleaner(LocalObjectsCleaner localObjectsCleaner)

clusterPeer

public Stage.Builder clusterPeer(ClusterPeer clusterPeer)

objectCloner

public Stage.Builder objectCloner(ExecutionObjectCloner objectCloner)

messageSerializer

public Stage.Builder messageSerializer(MessageSerializer messageSerializer)

messageLoopbackObjectCloner

public Stage.Builder messageLoopbackObjectCloner(ExecutionObjectCloner messageLoopbackObjectCloner)

messaging

public Stage.Builder messaging(Messaging messaging)

invocationHandler

public Stage.Builder invocationHandler(InvocationHandler invocationHandler)

clusterName

public Stage.Builder clusterName(String clusterName)

placementGroup

public Stage.Builder placementGroup(String placementGroup)

nodeName

public Stage.Builder nodeName(String nodeName)

mode

public Stage.Builder mode(Stage.StageMode mode)

extensions

public Stage.Builder extensions(Collection<ActorExtension> extensions)

extensions

public Stage.Builder extensions(ActorExtension... extensions)

stickyHeaders

public Stage.Builder stickyHeaders(String... stickyHeaders)

basePackages

public Stage.Builder basePackages(String... basePackages)

basePackages

public Stage.Builder basePackages(Collection<String> basePackages)

timer

public Stage.Builder timer(Timer timer)

actorTTL

public Stage.Builder actorTTL(long duration,
                              TimeUnit timeUnit)

localAddressCacheTTL

public Stage.Builder localAddressCacheTTL(long duration,
                                          TimeUnit timeUnit)

numReminderControllers

public Stage.Builder numReminderControllers(int numReminderControllers)

deactivationTimeout

public Stage.Builder deactivationTimeout(long duration,
                                         TimeUnit timeUnit)

concurrentDeactivations

public Stage.Builder concurrentDeactivations(int concurrentDeactivations)

broadcastActorDeactivations

public Stage.Builder broadcastActorDeactivations(boolean broadcastActorDeactivations)

enableShutdownHook

public Stage.Builder enableShutdownHook(boolean enableShutdownHook)

flushPlacementGroupCache

public Stage.Builder flushPlacementGroupCache(boolean flushPlacementGroupCache)

build

public Stage build()