Package | Description |
---|---|
org.opennms.core.ipc.sink.api | |
org.opennms.core.ipc.sink.offheap |
Modifier and Type | Method and Description |
---|---|
DispatchQueue.EnqueueResult |
DispatchQueue.enqueue(T message,
String key)
Adds the message to the tail of the queue blocking if the queue is currently full.
|
static DispatchQueue.EnqueueResult |
DispatchQueue.EnqueueResult.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static DispatchQueue.EnqueueResult[] |
DispatchQueue.EnqueueResult.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
DispatchQueue.EnqueueResult |
QueueFileOffHeapDispatchQueue.enqueue(T message,
String key)
When enqueueing we prefer the in-memory queue unless the file based queue is already utilized.
|
Copyright © 2020. All rights reserved.