Package | Description |
---|---|
org.opennms.core.ipc.sink.api | |
org.opennms.core.ipc.sink.offheap |
Modifier and Type | Method and Description |
---|---|
<T> DispatchQueue<T> |
DispatchQueueFactory.getQueue(AsyncPolicy asyncPolicy,
String moduleName,
java.util.function.Function<T,byte[]> serializer,
java.util.function.Function<byte[],T> deserializer) |
Modifier and Type | Class and Description |
---|---|
class |
QueueFileOffHeapDispatchQueue<T>
A
DispatchQueue that first attempts to queue items in memory and upon overflowing the allocated in-memory
queue writes items "off heap" directly to disk via a file. |
Modifier and Type | Method and Description |
---|---|
<T> DispatchQueue<T> |
QueueFileOffHeapDispatchQueueFactory.getQueue(AsyncPolicy asyncPolicy,
String moduleName,
java.util.function.Function<T,byte[]> serializer,
java.util.function.Function<byte[],T> deserializer) |
Copyright © 2020. All rights reserved.