public static class ChronicleQueueBuilder.VanillaChronicleQueueBuilder extends ChronicleQueueBuilder
ChronicleQueueBuilder.IndexedChronicleQueueBuilder, ChronicleQueueBuilder.ReplicaChronicleQueueBuilder, ChronicleQueueBuilder.VanillaChronicleQueueBuilder
indexed, indexed, indexed, indexed, remoteAppender, remoteTailer, sink, source, vanilla, vanilla, vanilla, vanilla
protected File path()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder synchronous(boolean synchronous)
ExcerptCommon.finish()
will force a persistence every time.synchronous
- If synchronous mode should be used or not.public boolean syncOnRoll()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder syncOnRoll(boolean syncOnRoll)
public boolean synchronous()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder useCheckedExcerpt(boolean useCheckedExcerpt)
useCheckedExcerpt
- public boolean useCheckedExcerpt()
public boolean useCompressedObjectSerializer()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder useCompressedObjectSerializer(boolean useCompressedObjectSerializer)
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cycleFormat(String cycleFormat)
public String cycleFormat()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cycleLength(int cycleLength)
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cycleLength(int cycleLength, boolean check)
public int cycleLength()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cycleTimeZone(String timeZone)
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cycleTimeZone(TimeZone timeZone)
public TimeZone cycleTimeZone()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder indexBlockSize(long indexBlockSize)
public long indexBlockSize()
public long dataBlockSize()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder dataBlockSize(long dataBlockSize)
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cycle(VanillaChronicle.Cycle cycle)
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder entriesPerCycle(long entriesPerCycle)
public long entriesPerCycle()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder defaultMessageSize(int defaultMessageSize)
public int defaultMessageSize()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder cleanupOnClose(boolean cleanupOnClose)
public boolean cleanupOnClose()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder dataCacheCapacity(int dataCacheCapacity)
public int dataCacheCapacity()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder indexCacheCapacity(int indexCacheCapacity)
public int indexCacheCapacity()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder sink()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder source()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder fileLifecycleListener(net.openhft.lang.io.FileLifecycleListener fileLifecycleListener)
public net.openhft.lang.io.FileLifecycleListener fileLifecycleListener()
public boolean enableFsWatcher()
public ChronicleQueueBuilder.VanillaChronicleQueueBuilder enableFsWatcher(boolean enableFsWatcher)
public Chronicle build() throws IOException
build
in class ChronicleQueueBuilder
IOException
@NotNull public ChronicleQueueBuilder.VanillaChronicleQueueBuilder clone()
clone
in class ChronicleQueueBuilder
Copyright © 2017. All rights reserved.