Package org.opennms.core.ipc.sink.offheap

Class QueueFileOffHeapDispatchQueueFactory

java.lang.Object

org.opennms.core.ipc.sink.offheap.QueueFileOffHeapDispatchQueueFactory

All Implemented Interfaces:

DispatchQueueFactory

public class QueueFileOffHeapDispatchQueueFactory
extends Object
implements DispatchQueueFactory

Constructor Summary

Constructors

Constructor	Description
QueueFileOffHeapDispatchQueueFactory(int inMemoryEntrySize, int batchSize, String offHeapSize, String baseFilePath)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueFileOffHeapDispatchQueueFactory

public QueueFileOffHeapDispatchQueueFactory(int inMemoryEntrySize,
                                            int batchSize,
                                            String offHeapSize,
                                            String baseFilePath)

Method Detail

getQueue

public <T> DispatchQueue<T> getQueue(AsyncPolicy asyncPolicy,
                                     String moduleName,
                                     java.util.function.Function<T,byte[]> serializer,
                                     java.util.function.Function<byte[],T> deserializer)

Specified by:

getQueue in interface DispatchQueueFactory