final class MessageBufferMap[I] extends AnyRef
A non thread safe mutable message buffer map that can be used to buffer messages inside actors.
- I
(Id type)
- Source
- MessageBuffer.scala
- Alphabetic
- By Inheritance
- MessageBufferMap
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new MessageBufferMap()
Value Members
- def add(id: I): Unit
Add an id to the buffer map
- def append(id: I, message: Any, ref: ActorRef): Unit
Append an element to the buffer for an id.
Append an element to the buffer for an id.
- id
the id to add the element to
- message
the message to buffer
- ref
the actor to buffer
- def contains(id: I): Boolean
Check if the buffer map contains an id.
Check if the buffer map contains an id.
- id
the id to check for
- returns
if the buffer contains the given id
- def drop(id: I, reason: String, deadLetters: ActorRef): Int
Remove the buffer for an id, but publish a akka.actor.Dropped for each dropped buffered message
Remove the buffer for an id, but publish a akka.actor.Dropped for each dropped buffered message
- returns
how many buffered messages were dropped
- def forEach(f: Procedure2[I, MessageBuffer]): Unit
Java API
Java API
Iterate over all elements of the buffer map and apply a function to each element.
- f
the function to apply to each element
- def foreach(f: (I, MessageBuffer) => Unit): Unit
Iterate over all elements of the buffer map and apply a function to each element.
Iterate over all elements of the buffer map and apply a function to each element.
- f
the function to apply to each element
- def getOrEmpty(id: I): MessageBuffer
Get the message buffer for an id, or an empty buffer if the id doesn't exist in the map.
Get the message buffer for an id, or an empty buffer if the id doesn't exist in the map.
- id
the id to get the message buffer for
- returns
the message buffer for the given id or an empty buffer if the id doesn't exist
- def isEmpty: Boolean
Check if the buffer map is empty.
Check if the buffer map is empty.
- returns
if the buffer map is empty
- def nonEmpty: Boolean
Check if the buffer map is not empty.
Check if the buffer map is not empty.
- returns
if the buffer map is not empty
- def remove(id: I): Unit
Remove the buffer for an id.
Remove the buffer for an id.
- id
the id to remove the buffer for
- def size: Int
How many ids are in the buffer map.
How many ids are in the buffer map.
- returns
the number of ids in the buffer map
- def totalSize: Int
How many elements are in the buffers in the buffer map.
How many elements are in the buffers in the buffer map.
- returns
the number of elements in the buffers in the buffer map