Package org.opennms.core.ipc.sink.api
Interface DispatchQueueFactory
-
- All Known Implementing Classes:
QueueFileOffHeapDispatchQueueFactory
public interface DispatchQueueFactory
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> DispatchQueue<T>getQueue(AsyncPolicy asyncPolicy, String moduleName, java.util.function.Function<T,byte[]> serializer, java.util.function.Function<byte[],T> deserializer)
-
-
-
Method Detail
-
getQueue
<T> DispatchQueue<T> getQueue(AsyncPolicy asyncPolicy, String moduleName, java.util.function.Function<T,byte[]> serializer, java.util.function.Function<byte[],T> deserializer)
-
-