Skip navigation links
A C D E H I J L M N O P Q R S T U W 

A

ack() - Method in class akka.contrib.mailbox.PeekMailbox
 
ack(ActorContext) - Method in class akka.contrib.mailbox.PeekMailboxExtension$
 
ack(ActorContext) - Method in class akka.contrib.mailbox.PeekMailboxExtension
 
active() - Method in class akka.contrib.pattern.ReliableProxy$
 
active() - Static method in class akka.contrib.pattern.ReliableProxy
 
Active$() - Constructor for class akka.contrib.pattern.ReliableProxy.Active$
 
Active$() - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Active$
 
actor() - Method in class akka.contrib.pattern.ReliableProxy.ProxyTerminated
 
add(T, boolean) - Method in class akka.contrib.pattern.WorkList
Appends an entry to the work list.
addAll(WorkList<T>) - Method in class akka.contrib.pattern.WorkList
Appends another WorkList to this WorkList.
addBuffer() - Method in interface akka.contrib.pattern.Aggregator
 
addSelf(String) - Method in interface akka.contrib.pattern.ReliableProxyDebugLogging
 
after() - Method in class akka.contrib.pattern.ReceivePipeline.InnerAndAfter
 
Aggregator - Interface in akka.contrib.pattern
The aggregator is to be mixed into an actor for the aggregator behavior.
akka.contrib.jul - package akka.contrib.jul
 
akka.contrib.mailbox - package akka.contrib.mailbox
 
akka.contrib.pattern - package akka.contrib.pattern
 
akka.contrib.throttle - package akka.contrib.throttle
 
andAfter(Function0<BoxedUnit>) - Method in class akka.contrib.pattern.ReceivePipeline.Inner
Add a block of code to be executed after the message (which may be further transformed and processed by inner interceptors) is handled by the actor's receive.
aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.contrib.pattern.ReceivePipeline
INTERNAL API.
attemptedReconnects() - Method in class akka.contrib.pattern.ReliableProxy
 

C

callsLeftInThisPeriod() - Method in class akka.contrib.throttle.TimerBasedThrottler.Data
 
cleanUp(ActorRef, MessageQueue) - Method in class akka.contrib.mailbox.PeekMailbox
 
combinedDecorator() - Method in interface akka.contrib.pattern.ReceivePipeline
 
compare(int, int) - Method in class akka.contrib.pattern.ReliableProxy$
Wrap-around aware comparison of integers: differences limited to 2**31-1 in magnitude will work correctly.
compare(int, int) - Static method in class akka.contrib.pattern.ReliableProxy
Wrap-around aware comparison of integers: differences limited to 2**31-1 in magnitude will work correctly.
Connecting$() - Constructor for class akka.contrib.pattern.ReliableProxy.Connecting$
 
create(Option<ActorRef>, Option<ActorSystem>) - Method in class akka.contrib.mailbox.PeekMailboxType
 
createExtension(ExtendedActorSystem) - Method in class akka.contrib.mailbox.PeekMailboxExtension$
 
createExtension(ExtendedActorSystem) - Static method in class akka.contrib.mailbox.PeekMailboxExtension
 
createTunnel(ActorRef) - Method in class akka.contrib.pattern.ReliableProxy
 
currentSerial() - Method in class akka.contrib.pattern.ReliableProxy
 
currentTarget() - Method in class akka.contrib.pattern.ReliableProxy
 

D

Data(Option<ActorRef>, int, Queue<TimerBasedThrottler.Message>) - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Data
 
Data$() - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Data$
 
debug() - Method in interface akka.contrib.pattern.ReliableProxyDebugLogging
 
decoratorCache() - Method in interface akka.contrib.pattern.ReceivePipeline
 
defaultConnectInterval() - Method in class akka.contrib.pattern.ReliableProxy
 
dequeue() - Method in class akka.contrib.mailbox.PeekMailbox
 
Done$() - Constructor for class akka.contrib.pattern.ReceivePipeline.Done$
 
duration() - Method in class akka.contrib.throttle.Throttler.Rate
 
durationInMillis() - Method in class akka.contrib.throttle.Throttler.Rate
The duration in milliseconds.

E

empty() - Method in class akka.contrib.pattern.WorkList$
 
empty() - Static method in class akka.contrib.pattern.WorkList
 
enabled() - Method in interface akka.contrib.pattern.ReliableProxyDebugLogging
 
Entry(Option<T>, boolean) - Constructor for class akka.contrib.pattern.WorkList.Entry
 
expect(PartialFunction<Object, BoxedUnit>) - Method in interface akka.contrib.pattern.Aggregator
Adds the partial function to the receive set and keeping it in the receive set till removed.
expectList() - Method in interface akka.contrib.pattern.Aggregator
 
expectOnce(PartialFunction<Object, BoxedUnit>) - Method in interface akka.contrib.pattern.Aggregator
Adds the partial function to the receive set, to be removed on first match.

H

HandledCompletely$() - Constructor for class akka.contrib.pattern.ReceivePipeline.HandledCompletely$
 
handleMessage(Object) - Method in interface akka.contrib.pattern.Aggregator
Handles messages and matches against the expect list.
head() - Method in class akka.contrib.pattern.WorkList
 

I

idle() - Method in class akka.contrib.pattern.ReliableProxy$
 
idle() - Static method in class akka.contrib.pattern.ReliableProxy
 
Idle$() - Constructor for class akka.contrib.pattern.ReliableProxy.Idle$
 
Idle$() - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Idle$
 
initialState() - Method in class akka.contrib.pattern.ReliableProxy
 
Inner(Object) - Constructor for class akka.contrib.pattern.ReceivePipeline.Inner
 
Inner$() - Constructor for class akka.contrib.pattern.ReceivePipeline.Inner$
 
InnerAndAfter(Object, Function1<BoxedUnit, BoxedUnit>) - Constructor for class akka.contrib.pattern.ReceivePipeline.InnerAndAfter
 
InnerAndAfter$() - Constructor for class akka.contrib.pattern.ReceivePipeline.InnerAndAfter$
 
isDebugEnabled() - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
isDeleted() - Method in class akka.contrib.pattern.WorkList.Entry
 
isErrorEnabled() - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
isInfoEnabled() - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
isWarningEnabled() - Method in interface akka.contrib.jul.JavaLoggingAdapter
 

J

JavaLogger - Class in akka.contrib.jul
java.util.logging logger.
JavaLogger() - Constructor for class akka.contrib.jul.JavaLogger
 
JavaLogging - Interface in akka.contrib.jul
Makes the Akka Logging API available as the log field, using java.util.logging as the backend.
JavaLoggingAdapter - Interface in akka.contrib.jul
 

L

lastAckSerial() - Method in class akka.contrib.pattern.ReliableProxy
 
lastSerial() - Method in class akka.contrib.pattern.ReliableProxy.Receiver
 
log(Level, Throwable, Logging.LogEvent) - Method in class akka.contrib.jul.JavaLogger
 
log() - Method in interface akka.contrib.jul.JavaLogging
 
log(Level, Throwable, String) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
logDebug(String, Object, Object) - Method in interface akka.contrib.pattern.ReliableProxyDebugLogging
 
logDebug(String, Object) - Method in interface akka.contrib.pattern.ReliableProxyDebugLogging
 
logger() - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
loggingExecutionContext() - Method in interface akka.contrib.jul.JavaLoggingAdapter
Override-able option for asynchronous logging
logResend(int) - Method in class akka.contrib.pattern.ReliableProxy
 
lookup() - Method in class akka.contrib.mailbox.PeekMailboxExtension$
 
lookup() - Static method in class akka.contrib.mailbox.PeekMailboxExtension
 

M

Marker() - Method in class akka.contrib.mailbox.PeekMailbox
 
Message(Object, ActorRef, int) - Constructor for class akka.contrib.pattern.ReliableProxy.Message
 
Message(Object, ActorRef) - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Message
 
message() - Method in class akka.contrib.throttle.TimerBasedThrottler.Message
 
Message$() - Constructor for class akka.contrib.pattern.ReliableProxy.Message$
 
Message$() - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Message$
 
MODULE$ - Static variable in class akka.contrib.mailbox.PeekMailboxExtension$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReceivePipeline$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReceivePipeline.Done$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReceivePipeline.HandledCompletely$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReceivePipeline.Inner$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReceivePipeline.InnerAndAfter$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReceivePipeline.Undefined$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.Active$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.Connecting$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.Idle$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.Message$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.ProxyTerminated$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.TargetChanged$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.ReliableProxy.Unsent$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.pattern.WorkList$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.Throttler$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.Throttler.Rate$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.Throttler.RateInt$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.Throttler.SetRate$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.Throttler.SetTarget$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.TimerBasedThrottler$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.TimerBasedThrottler.Active$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.TimerBasedThrottler.Data$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.TimerBasedThrottler.Idle$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.TimerBasedThrottler.Message$
Static reference to the singleton instance of this Scala object.
MODULE$ - Static variable in class akka.contrib.throttle.TimerBasedThrottler.Tick$
Static reference to the singleton instance of this Scala object.
msg() - Method in class akka.contrib.pattern.ReliableProxy.Message
 
msgsPer(int, TimeUnit) - Method in class akka.contrib.throttle.Throttler.RateInt
 
msgsPer(FiniteDuration) - Method in class akka.contrib.throttle.Throttler.RateInt
 
msgsPerHour() - Method in class akka.contrib.throttle.Throttler.RateInt
 
msgsPerMinute() - Method in class akka.contrib.throttle.Throttler.RateInt
 
msgsPerSecond() - Method in class akka.contrib.throttle.Throttler.RateInt
 

N

next() - Method in class akka.contrib.pattern.WorkList.Entry
 
nextBackoff() - Method in class akka.contrib.pattern.ReliableProxy
Returns the next retry interval duration.
nextSerial() - Method in class akka.contrib.pattern.ReliableProxy
 
notifyDebug(String) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
notifyError(String) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
notifyError(Throwable, String) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
notifyInfo(String) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
notifyWarning(String) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 
numberOfCalls() - Method in class akka.contrib.throttle.Throttler.Rate
 
numberOfCalls() - Method in class akka.contrib.throttle.Throttler.RateInt
 

O

outstanding() - Method in class akka.contrib.pattern.ReliableProxy.ProxyTerminated
 

P

PeekMailbox - Class in akka.contrib.mailbox
 
PeekMailbox(ActorRef, ActorSystem, int) - Constructor for class akka.contrib.mailbox.PeekMailbox
 
PeekMailboxExtension - Class in akka.contrib.mailbox
 
PeekMailboxExtension(ExtendedActorSystem) - Constructor for class akka.contrib.mailbox.PeekMailboxExtension
 
PeekMailboxExtension$ - Class in akka.contrib.mailbox
 
PeekMailboxExtension$() - Constructor for class akka.contrib.mailbox.PeekMailboxExtension$
 
PeekMailboxType - Class in akka.contrib.mailbox
configure the mailbox via dispatcher configuration:
PeekMailboxType(ActorSystem.Settings, Config) - Constructor for class akka.contrib.mailbox.PeekMailboxType
 
permanent() - Method in class akka.contrib.pattern.WorkList.Entry
 
pipeline() - Method in interface akka.contrib.pattern.ReceivePipeline
 
pipelineInner(PartialFunction<Object, ReceivePipeline.Delegation>) - Method in interface akka.contrib.pattern.ReceivePipeline
Adds an inner interceptor, it will be applied lastly, near to Actor's original behavior
pipelineOuter(PartialFunction<Object, ReceivePipeline.Delegation>) - Method in interface akka.contrib.pattern.ReceivePipeline
Adds an outer interceptor, it will be applied firstly, far from Actor's original behavior
postStop() - Method in class akka.contrib.pattern.ReliableProxy
 
process(Function1<T, Object>) - Method in class akka.contrib.pattern.WorkList
Tries to process each entry using the processing function.
processing() - Method in interface akka.contrib.pattern.Aggregator
 
props(ActorPath, FiniteDuration, Option<FiniteDuration>, Option<Object>) - Method in class akka.contrib.pattern.ReliableProxy$
Scala API Props.
props(ActorPath, FiniteDuration, FiniteDuration, int) - Method in class akka.contrib.pattern.ReliableProxy$
Java API Props.
props(ActorPath, FiniteDuration, FiniteDuration) - Method in class akka.contrib.pattern.ReliableProxy$
Props with no limit on reconnections.
props(ActorPath, FiniteDuration) - Method in class akka.contrib.pattern.ReliableProxy$
Props with no reconnections.
props(ActorPath, FiniteDuration, Option<FiniteDuration>, Option<Object>) - Static method in class akka.contrib.pattern.ReliableProxy
Scala API Props.
props(ActorPath, FiniteDuration, FiniteDuration, int) - Static method in class akka.contrib.pattern.ReliableProxy
Java API Props.
props(ActorPath, FiniteDuration, FiniteDuration) - Static method in class akka.contrib.pattern.ReliableProxy
Props with no limit on reconnections.
props(ActorPath, FiniteDuration) - Static method in class akka.contrib.pattern.ReliableProxy
Props with no reconnections.
ProxyTerminated(ActorRef, ReliableProxy.Unsent) - Constructor for class akka.contrib.pattern.ReliableProxy.ProxyTerminated
 
ProxyTerminated$() - Constructor for class akka.contrib.pattern.ReliableProxy.ProxyTerminated$
 

Q

queue() - Method in class akka.contrib.mailbox.PeekMailbox
 
queue() - Method in class akka.contrib.pattern.ReliableProxy.Unsent
 
queue() - Method in class akka.contrib.throttle.TimerBasedThrottler.Data
 

R

Rate(int, FiniteDuration) - Constructor for class akka.contrib.throttle.Throttler.Rate
 
rate() - Method in class akka.contrib.throttle.Throttler.SetRate
 
rate() - Method in class akka.contrib.throttle.TimerBasedThrottler
 
Rate$() - Constructor for class akka.contrib.throttle.Throttler.Rate$
 
RateInt(int) - Constructor for class akka.contrib.throttle.Throttler.RateInt
 
RateInt$() - Constructor for class akka.contrib.throttle.Throttler.RateInt$
 
receive() - Method in class akka.contrib.jul.JavaLogger
 
receive() - Method in interface akka.contrib.pattern.Aggregator
Receive function for handling the aggregations.
receive() - Method in class akka.contrib.pattern.ReliableProxy.Receiver
 
ReceivePipeline - Interface in akka.contrib.pattern
Trait implementing Receive Pipeline Pattern.
ReceivePipeline$ - Class in akka.contrib.pattern
 
ReceivePipeline$() - Constructor for class akka.contrib.pattern.ReceivePipeline$
 
ReceivePipeline.Delegation - Interface in akka.contrib.pattern
Result returned by an interceptor PF to determine what/whether to delegate to the next inner interceptor
ReceivePipeline.Done$ - Class in akka.contrib.pattern
 
ReceivePipeline.HandledCompletely$ - Class in akka.contrib.pattern
Interceptor return value that indicates that the message has been handled completely.
ReceivePipeline.HandlerResult - Interface in akka.contrib.pattern
 
ReceivePipeline.Inner - Class in akka.contrib.pattern
 
ReceivePipeline.Inner$ - Class in akka.contrib.pattern
 
ReceivePipeline.InnerAndAfter - Class in akka.contrib.pattern
 
ReceivePipeline.InnerAndAfter$ - Class in akka.contrib.pattern
 
ReceivePipeline.Undefined$ - Class in akka.contrib.pattern
 
receiver(ActorRef, int) - Method in class akka.contrib.pattern.ReliableProxy$
 
receiver(ActorRef, int) - Static method in class akka.contrib.pattern.ReliableProxy
 
Receiver(ActorRef, int) - Constructor for class akka.contrib.pattern.ReliableProxy.Receiver
 
reconnecting() - Method in class akka.contrib.pattern.ReliableProxy$
 
reconnecting() - Static method in class akka.contrib.pattern.ReliableProxy
 
reconnectTimer() - Method in class akka.contrib.pattern.ReliableProxy
 
ref() - Method in class akka.contrib.pattern.ReliableProxy.TargetChanged
 
ref() - Method in class akka.contrib.pattern.WorkList.Entry
 
register(ActorRef, PeekMailbox) - Method in class akka.contrib.mailbox.PeekMailboxExtension
 
ReliableProxy - Class in akka.contrib.pattern
A ReliableProxy is a means to wrap a remote actor reference in order to obtain certain improved delivery guarantees:
ReliableProxy(ActorPath, FiniteDuration, Option<FiniteDuration>, Option<Object>) - Constructor for class akka.contrib.pattern.ReliableProxy
 
ReliableProxy$ - Class in akka.contrib.pattern
 
ReliableProxy$() - Constructor for class akka.contrib.pattern.ReliableProxy$
 
ReliableProxy.Active$ - Class in akka.contrib.pattern
 
ReliableProxy.Connecting$ - Class in akka.contrib.pattern
 
ReliableProxy.Idle$ - Class in akka.contrib.pattern
 
ReliableProxy.Message - Class in akka.contrib.pattern
 
ReliableProxy.Message$ - Class in akka.contrib.pattern
 
ReliableProxy.ProxyTerminated - Class in akka.contrib.pattern
ProxyTerminated is sent to transition subscribers during postStop.
ReliableProxy.ProxyTerminated$ - Class in akka.contrib.pattern
 
ReliableProxy.Receiver - Class in akka.contrib.pattern
 
ReliableProxy.State - Interface in akka.contrib.pattern
 
ReliableProxy.TargetChanged - Class in akka.contrib.pattern
TargetChanged is sent to transition subscribers when the initial connection is made the target and when the target ActorRef has changed (for example, the target system crashed and has been restarted).
ReliableProxy.TargetChanged$ - Class in akka.contrib.pattern
 
ReliableProxy.Unsent - Class in akka.contrib.pattern
 
ReliableProxy.Unsent$ - Class in akka.contrib.pattern
 
ReliableProxyDebugLogging - Interface in akka.contrib.pattern
INTERNAL API
remove(T) - Method in class akka.contrib.pattern.WorkList
Removes an entry from the work list
removeAll() - Method in class akka.contrib.pattern.WorkList
Removes all entries from this WorkList
resend(Vector<ReliableProxy.Message>) - Method in class akka.contrib.pattern.ReliableProxy
 
resendTimer() - Method in class akka.contrib.pattern.ReliableProxy
 
resetBackoff() - Method in class akka.contrib.pattern.ReliableProxy
Reset backoff interval.
retryGateClosedFor() - Method in class akka.contrib.pattern.ReliableProxy
 

S

scheduleReconnectTick() - Method in class akka.contrib.pattern.ReliableProxy
 
scheduleTick() - Method in class akka.contrib.pattern.ReliableProxy
 
send(Object, ActorRef) - Method in class akka.contrib.pattern.ReliableProxy
 
sender() - Method in class akka.contrib.pattern.ReliableProxy.Message
 
sender() - Method in class akka.contrib.throttle.TimerBasedThrottler.Message
 
serial() - Method in class akka.contrib.pattern.ReliableProxy.Message
 
SetRate(Throttler.Rate) - Constructor for class akka.contrib.throttle.Throttler.SetRate
 
SetRate$() - Constructor for class akka.contrib.throttle.Throttler.SetRate$
 
SetTarget(Option<ActorRef>) - Constructor for class akka.contrib.throttle.Throttler.SetTarget
 
SetTarget(ActorRef) - Constructor for class akka.contrib.throttle.Throttler.SetTarget
Java API:
SetTarget$() - Constructor for class akka.contrib.throttle.Throttler.SetTarget$
 
supervisorStrategy() - Method in class akka.contrib.pattern.ReliableProxy
 
system() - Method in class akka.contrib.mailbox.PeekMailboxExtension
 

T

tail() - Method in class akka.contrib.pattern.WorkList
 
target() - Method in class akka.contrib.throttle.Throttler.SetTarget
 
target() - Method in class akka.contrib.throttle.TimerBasedThrottler.Data
 
TargetChanged(ActorRef) - Constructor for class akka.contrib.pattern.ReliableProxy.TargetChanged
 
TargetChanged$() - Constructor for class akka.contrib.pattern.ReliableProxy.TargetChanged$
 
terminated() - Method in class akka.contrib.pattern.ReliableProxy
 
Throttler - Class in akka.contrib.throttle
 
Throttler() - Constructor for class akka.contrib.throttle.Throttler
 
Throttler$ - Class in akka.contrib.throttle
 
Throttler$() - Constructor for class akka.contrib.throttle.Throttler$
 
Throttler.Rate - Class in akka.contrib.throttle
A rate used for throttling.
Throttler.Rate$ - Class in akka.contrib.throttle
 
Throttler.RateInt - Class in akka.contrib.throttle
Helper for some syntactic sugar.
Throttler.RateInt$ - Class in akka.contrib.throttle
 
Throttler.SetRate - Class in akka.contrib.throttle
Set the rate of a throttler.
Throttler.SetRate$ - Class in akka.contrib.throttle
 
Throttler.SetTarget - Class in akka.contrib.throttle
Set the target of a throttler.
Throttler.SetTarget$ - Class in akka.contrib.throttle
 
Tick$() - Constructor for class akka.contrib.throttle.TimerBasedThrottler.Tick$
 
TimerBasedThrottler - Class in akka.contrib.throttle
A throttler that uses a timer to control the message delivery rate.
TimerBasedThrottler(Throttler.Rate) - Constructor for class akka.contrib.throttle.TimerBasedThrottler
 
TimerBasedThrottler$ - Class in akka.contrib.throttle
INTERNAL API
TimerBasedThrottler$() - Constructor for class akka.contrib.throttle.TimerBasedThrottler$
 
TimerBasedThrottler.Active$ - Class in akka.contrib.throttle
 
TimerBasedThrottler.Data - Class in akka.contrib.throttle
 
TimerBasedThrottler.Data$ - Class in akka.contrib.throttle
 
TimerBasedThrottler.Idle$ - Class in akka.contrib.throttle
 
TimerBasedThrottler.Message - Class in akka.contrib.throttle
 
TimerBasedThrottler.Message$ - Class in akka.contrib.throttle
 
TimerBasedThrottler.State - Interface in akka.contrib.throttle
 
TimerBasedThrottler.Tick$ - Class in akka.contrib.throttle
 
toReceive(Function1<Object, ReceivePipeline.HandlerResult>) - Method in interface akka.contrib.pattern.ReceivePipeline
 
transformedMsg() - Method in class akka.contrib.pattern.ReceivePipeline.Inner
 
transformedMsg() - Method in class akka.contrib.pattern.ReceivePipeline.InnerAndAfter
 
tries() - Method in class akka.contrib.mailbox.PeekMailbox
 
tunnel() - Method in class akka.contrib.pattern.ReliableProxy
 

U

Undefined$() - Constructor for class akka.contrib.pattern.ReceivePipeline.Undefined$
 
unexpect(PartialFunction<Object, BoxedUnit>) - Method in interface akka.contrib.pattern.Aggregator
Removes the partial function from the receive set.
unregister(ActorRef) - Method in class akka.contrib.mailbox.PeekMailboxExtension
 
Unsent(Vector<ReliableProxy.Message>) - Constructor for class akka.contrib.pattern.ReliableProxy.Unsent
 
Unsent$() - Constructor for class akka.contrib.pattern.ReliableProxy.Unsent$
 
updateSerial(Vector<ReliableProxy.Message>) - Method in class akka.contrib.pattern.ReliableProxy
 
updateSource(LogRecord) - Method in interface akka.contrib.jul.JavaLoggingAdapter
 

W

WorkList<T> - Class in akka.contrib.pattern
Fast, small, and dirty implementation of a linked list that removes transient work entries once they are processed.
WorkList() - Constructor for class akka.contrib.pattern.WorkList
 
WorkList$ - Class in akka.contrib.pattern
Provides the utility methods and constructors to the WorkList class.
WorkList$() - Constructor for class akka.contrib.pattern.WorkList$
 
WorkList.Entry<T> - Class in akka.contrib.pattern
Singly linked list entry implementation for WorkList.
A C D E H I J L M N O P Q R S T U W 
Skip navigation links