| Package | Description |
|---|---|
| com.caucho.bam.mailbox | |
| com.caucho.cloud.bam | |
| com.caucho.env.actor | |
| com.caucho.message.journal |
| Modifier and Type | Method and Description |
|---|---|
protected ActorProcessor<Packet> |
MultiworkerMailbox.createProcessor() |
| Constructor and Description |
|---|
MailboxQueue2(int capacity,
ActorProcessor<Packet> processor) |
| Modifier and Type | Class and Description |
|---|---|
class |
HmuxWorker
Queue of hmtp packets
|
| Modifier and Type | Method and Description |
|---|---|
protected ActorProcessor<Packet> |
HmuxQueue.createProcessor() |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractActorProcessor<T>
Processes an actor item.
|
class |
AbstractWorkerQueue<T>
Ring-based memory queue processed by a single worker.
|
| Modifier and Type | Method and Description |
|---|---|
ActorQueueApi<T> |
ActorQueueBuilder.build(ActorProcessor<? super T>... processors) |
| Constructor and Description |
|---|
ActorQueue(int capacity,
RingItemFactory<T> itemFactory,
ActorProcessor<? super T>... processors) |
MultiworkerActorQueue(int capacity,
int multiworkerOffset,
ActorProcessor<? super T>... processors) |
ValueActorQueue(int capacity,
ActorProcessor<? super T>... processors) |
| Modifier and Type | Class and Description |
|---|---|
class |
JournalWriteActor
Actor-processor for writing to the transaction log.
|