public abstract static class ChronicleQueueBuilder.ReplicaChronicleQueueBuilder extends ChronicleQueueBuilder implements MappingProvider<ChronicleQueueBuilder.ReplicaChronicleQueueBuilder>
ChronicleQueueBuilder.IndexedChronicleQueueBuilder, ChronicleQueueBuilder.ReplicaChronicleQueueBuilder, ChronicleQueueBuilder.VanillaChronicleQueueBuilder
Modifier and Type | Field and Description |
---|---|
static TcpConnectionListener |
CONNECTION_LISTENER |
static int |
DEFAULT_SOCKET_BUFFER_SIZE |
indexed, indexed, indexed, indexed, remoteAppender, remoteTailer, sink, source, vanilla, vanilla, vanilla, vanilla
public static final int DEFAULT_SOCKET_BUFFER_SIZE
public static final TcpConnectionListener CONNECTION_LISTENER
public InetSocketAddress bindAddress()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder bindAddress(InetSocketAddress bindAddress)
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder bindAddress(int port)
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder bindAddress(String host, int port)
public AddressProvider bindAddressProvider()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder bindAddressProvider(AddressProvider bindAddressProvider)
public InetSocketAddress connectAddress()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder connectAddress(InetSocketAddress connectAddress)
public AddressProvider connectAddressProvider()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder connectAddressProvider(AddressProvider connectAddressprovider)
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder connectAddress(String host, int port)
public long reconnectionreconnectionInterval()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder reconnectionInterval(long reconnectTimeout)
public long reconnectionIntervalMillis()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder reconnectionInterval(long reconnectionInterval, TimeUnit reconnectionIntervalUnit)
public TimeUnit reconnectionIntervalUnit()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder reconnectionIntervalUnit(TimeUnit reconnectionInterval)
public int reconnectionAttempts()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder reconnectionAttempts(int reconnectionAttempts)
public int reconnectionWarningThreshold()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder reconnectionWarningThreshold(int reconnectionWarningThreshold)
public long selectTimeout()
public long selectTimeoutMillis()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder selectTimeout(long selectTimeout, TimeUnit selectTimeoutUnit)
public TimeUnit selectTimeoutUnit()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder heartbeatInterval(long heartbeatInterval, TimeUnit heartbeatIntervalUnit)
public long heartbeatInterval()
public long heartbeatIntervalMillis()
public TimeUnit heartbeatIntervalUnit()
public int defaultSocketBufferSize()
public int receiveBufferSize()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder receiveBufferSize(int receiveBufferSize)
public int sendBufferSize()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder sendBufferSize(int sendBufferSize)
public int minBufferSize()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder minBufferSize(int minBufferSize)
public int maxExcerptsPerMessage()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder maxExcerptsPerMessage(int maxExcerptsPerMessage)
public boolean sharedChronicle()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder sharedChronicle(boolean sharedChronicle)
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder acceptorMaxBacklog(int acceptorMaxBacklog)
public int acceptorMaxBacklog()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder acceptorDefaultThreads(int acceptorDefaultThreads)
public int acceptorDefaultThreads()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder acceptorMaxThreads(int acceptorMaxThreads)
public int acceptorMaxThreads()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder acceptorThreadPoolkeepAlive(long acceptorThreadPoolKeepAliveTime, TimeUnit acceptorThreadPoolKeepAliveTimeUnit)
public long acceptorThreadPoolkeepAliveTime()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder acceptorThreadPoolkeepAliveTime(long acceptorThreadPoolKeepAliveTime)
public TimeUnit acceptorThreadPoolkeepAliveTimeUnit()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder acceptorThreadPoolkeepAliveTimeUnit(TimeUnit acceptorThreadPoolKeepAliveTimeUnit)
public long acceptorThreadPoolkeepAliveTimeMillis()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder busyPeriod(long busyPeriod, TimeUnit busyPeriodTimeUnit)
public long busyPeriod()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder busyPeriod(long busyPeriod)
public TimeUnit busyPeriodTimeUnit()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder busyPeriodTimeUnit(TimeUnit busyPeriodTimeUnit)
public long busyPeriodTimeNanos()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder parkPeriod(long parkPeriod, TimeUnit parkPeriodTimeUnit)
public long parkPeriod()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder parkPeriod(long parkPeriod)
public TimeUnit parkPeriodTimeUnit()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder parkPeriodTimeUnit(TimeUnit parkPeriodTimeUnit)
public long parkPeriodTimeNanos()
public int selectorSpinLoopCount()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder selectorSpinLoopCount(int selectorSpinLoopCount)
public int readSpinCount()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder readSpinCount(int readSpinCount)
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder connectionListener(TcpConnectionListener connectionListener)
public boolean hasConnectionListener()
public TcpConnectionListener connectionListener()
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder appendRequireAck(boolean appendRequireAck)
public boolean appendRequireAck()
public Chronicle chronicle()
public Chronicle build() throws IOException
build
in class ChronicleQueueBuilder
IOException
public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder withMapping(@Nullable @Nullable MappingFunction mapping)
mapping
is send from the sink to the source ( usually via TCP/IP ) this
mapping is then applied to the the source before the data is sent to the sinkwithMapping
in interface MappingProvider<ChronicleQueueBuilder.ReplicaChronicleQueueBuilder>
mapping
- a mapping function which is sent to the sourepublic MappingFunction withMapping()
withMapping
in interface MappingProvider<ChronicleQueueBuilder.ReplicaChronicleQueueBuilder>
protected abstract Chronicle doBuild()
@NotNull public ChronicleQueueBuilder.ReplicaChronicleQueueBuilder clone()
clone
in class ChronicleQueueBuilder
Copyright © 2017. All rights reserved.