ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.acceptorDefaultThreads(int acceptorDefaultThreads) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.acceptorMaxBacklog(int acceptorMaxBacklog) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.acceptorMaxThreads(int acceptorMaxThreads) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.acceptorThreadPoolkeepAlive(long acceptorThreadPoolKeepAliveTime,
TimeUnit acceptorThreadPoolKeepAliveTimeUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.acceptorThreadPoolkeepAliveTime(long acceptorThreadPoolKeepAliveTime) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.acceptorThreadPoolkeepAliveTimeUnit(TimeUnit acceptorThreadPoolKeepAliveTimeUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.appendRequireAck(boolean appendRequireAck) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.bindAddress(InetSocketAddress bindAddress) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.bindAddress(int port) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.bindAddress(String host,
int port) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.bindAddressProvider(AddressProvider bindAddressProvider) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.busyPeriod(long busyPeriod) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.busyPeriod(long busyPeriod,
TimeUnit busyPeriodTimeUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.busyPeriodTimeUnit(TimeUnit busyPeriodTimeUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.clone()
Makes ReplicaChronicleQueueBuilder cloneable.
|
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.connectAddress(InetSocketAddress connectAddress) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.connectAddress(String host,
int port) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.connectAddressProvider(AddressProvider connectAddressprovider) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.connectionListener(TcpConnectionListener connectionListener) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.heartbeatInterval(long heartbeatInterval,
TimeUnit heartbeatIntervalUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.maxExcerptsPerMessage(int maxExcerptsPerMessage) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.minBufferSize(int minBufferSize) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.parkPeriod(long parkPeriod) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.parkPeriod(long parkPeriod,
TimeUnit parkPeriodTimeUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.parkPeriodTimeUnit(TimeUnit parkPeriodTimeUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.readSpinCount(int readSpinCount) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.receiveBufferSize(int receiveBufferSize) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.reconnectionAttempts(int reconnectionAttempts) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.reconnectionInterval(long reconnectTimeout) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.reconnectionInterval(long reconnectionInterval,
TimeUnit reconnectionIntervalUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.reconnectionIntervalUnit(TimeUnit reconnectionInterval) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.reconnectionWarningThreshold(int reconnectionWarningThreshold) |
static ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.remoteAppender() |
static ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.remoteTailer() |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.selectorSpinLoopCount(int selectorSpinLoopCount) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.selectTimeout(long selectTimeout,
TimeUnit selectTimeoutUnit) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.sendBufferSize(int sendBufferSize) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.sharedChronicle(boolean sharedChronicle) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.IndexedChronicleQueueBuilder.sink() |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.VanillaChronicleQueueBuilder.sink() |
static ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.sink(Chronicle chronicle) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.IndexedChronicleQueueBuilder.source() |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.VanillaChronicleQueueBuilder.source() |
static ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.source(Chronicle chronicle) |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder.withMapping(@Nullable MappingFunction mapping)
the 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 sink
|