ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setAuthDescriptor(AuthDescriptor to) |
Set the auth descriptor to enable authentication on new connections.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setAuthWaitTime(long authWaitTime) |
Set a custom wait time for the authentication on connect/reconnect.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setDaemon(boolean d) |
Set the daemon state of the IO thread (defaults to true).
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setEnableMetrics(MetricType type) |
Enable or disable metric collection.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setFailureMode(FailureMode fm) |
Set the failure mode.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setHashAlg(HashAlgorithm to) |
Set the hash algorithm.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setInitialObservers(java.util.Collection<ConnectionObserver> obs) |
Set the initial connection observers (will observe initial connection).
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setListenerExecutorService(java.util.concurrent.ExecutorService executorService) |
Set a custom ExecutorService to execute the listener callbacks.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setLocatorType(ConnectionFactoryBuilder.Locator l) |
Set the locator type.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setMaxReconnectDelay(long to) |
Set the maximum reconnect delay.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setMetricCollector(MetricCollector collector) |
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setOpFact(OperationFactory f) |
Set the operation factory.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setOpQueueFactory(OperationQueueFactory q) |
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setOpQueueMaxBlockTime(long t) |
Set the maximum amount of time (in milliseconds) a client is willing to
wait for space to become available in an output queue.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setOpTimeout(long t) |
Set the default operation timeout in milliseconds.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setProtocol(ConnectionFactoryBuilder.Protocol prot) |
Convenience method to specify the protocol to use.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setReadBufferSize(int to) |
Set the read buffer size.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setReadOpQueueFactory(OperationQueueFactory q) |
Set the read queue factory.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setShouldOptimize(boolean o) |
Set to false if the default operation optimization is not desirable.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setTimeoutExceptionThreshold(int to) |
Set the maximum timeout exception threshold.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setTranscoder(Transcoder<java.lang.Object> t) |
Set the default transcoder.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setUseNagleAlgorithm(boolean to) |
Set to true if you'd like to enable the Nagle algorithm.
|
ConnectionFactoryBuilder |
ConnectionFactoryBuilder.setWriteOpQueueFactory(OperationQueueFactory q) |
Set the write queue factory.
|