public class QueueFileOffHeapDispatchQueueFactory extends Object implements DispatchQueueFactory
Constructor and Description |
---|
QueueFileOffHeapDispatchQueueFactory(int inMemoryEntrySize,
int batchSize,
String offHeapSize,
String baseFilePath) |
Modifier and Type | Method and Description |
---|---|
<T> DispatchQueue<T> |
getQueue(AsyncPolicy asyncPolicy,
String moduleName,
java.util.function.Function<T,byte[]> serializer,
java.util.function.Function<byte[],T> deserializer) |
public <T> DispatchQueue<T> getQueue(AsyncPolicy asyncPolicy, String moduleName, java.util.function.Function<T,byte[]> serializer, java.util.function.Function<byte[],T> deserializer)
getQueue
in interface DispatchQueueFactory
Copyright © 2020. All rights reserved.