Uses of Interface
org.opennms.core.ipc.sink.api.DispatchQueue
-
Packages that use DispatchQueue Package Description org.opennms.core.ipc.sink.api org.opennms.core.ipc.sink.offheap -
-
Uses of DispatchQueue in org.opennms.core.ipc.sink.api
Methods in org.opennms.core.ipc.sink.api that return DispatchQueue Modifier and Type Method Description <T> DispatchQueue<T>
DispatchQueueFactory. getQueue(AsyncPolicy asyncPolicy, java.lang.String moduleName, java.util.function.Function<T,byte[]> serializer, java.util.function.Function<byte[],T> deserializer)
-
Uses of DispatchQueue in org.opennms.core.ipc.sink.offheap
Classes in org.opennms.core.ipc.sink.offheap that implement DispatchQueue Modifier and Type Class Description class
QueueFileOffHeapDispatchQueue<T>
ADispatchQueue
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.Methods in org.opennms.core.ipc.sink.offheap that return DispatchQueue Modifier and Type Method Description <T> DispatchQueue<T>
QueueFileOffHeapDispatchQueueFactory. getQueue(AsyncPolicy asyncPolicy, java.lang.String moduleName, java.util.function.Function<T,byte[]> serializer, java.util.function.Function<byte[],T> deserializer)
-