public class ConnectionParams extends Object
Constructor and Description |
---|
ConnectionParams() |
public CredentialsProvider getCredentialsProvider()
public ExecutorService getConsumerWorkServiceExecutor()
public String getVirtualHost()
public int getRequestedFrameMax()
public int getRequestedChannelMax()
public int getRequestedHeartbeat()
public int getHandshakeTimeout()
public void setHandshakeTimeout(int timeout)
public int getShutdownTimeout()
public SaslConfig getSaslConfig()
public ExceptionHandler getExceptionHandler()
public long getNetworkRecoveryInterval()
public RecoveryDelayHandler getRecoveryDelayHandler()
RecoveryDelayHandler.DefaultRecoveryDelayHandler
will be returned with a delay of getNetworkRecoveryInterval()
.public boolean isTopologyRecoveryEnabled()
public ExecutorService getTopologyRecoveryExecutor()
public ThreadFactory getThreadFactory()
public int getChannelRpcTimeout()
public boolean channelShouldCheckRpcResponseType()
public void setCredentialsProvider(CredentialsProvider credentialsProvider)
public void setConsumerWorkServiceExecutor(ExecutorService consumerWorkServiceExecutor)
public void setVirtualHost(String virtualHost)
public void setRequestedFrameMax(int requestedFrameMax)
public void setRequestedChannelMax(int requestedChannelMax)
public void setRequestedHeartbeat(int requestedHeartbeat)
public void setShutdownTimeout(int shutdownTimeout)
public void setSaslConfig(SaslConfig saslConfig)
public void setNetworkRecoveryInterval(long networkRecoveryInterval)
public void setRecoveryDelayHandler(RecoveryDelayHandler recoveryDelayHandler)
public void setTopologyRecovery(boolean topologyRecovery)
public void setTopologyRecoveryExecutor(ExecutorService topologyRecoveryExecutor)
public void setExceptionHandler(ExceptionHandler exceptionHandler)
public void setThreadFactory(ThreadFactory threadFactory)
public ExecutorService getShutdownExecutor()
public void setShutdownExecutor(ExecutorService shutdownExecutor)
public ScheduledExecutorService getHeartbeatExecutor()
public void setHeartbeatExecutor(ScheduledExecutorService heartbeatExecutor)
public void setChannelRpcTimeout(int channelRpcTimeout)
public void setChannelShouldCheckRpcResponseType(boolean channelShouldCheckRpcResponseType)
public void setErrorOnWriteListener(ErrorOnWriteListener errorOnWriteListener)
public ErrorOnWriteListener getErrorOnWriteListener()
public void setWorkPoolTimeout(int workPoolTimeout)
public int getWorkPoolTimeout()
public void setTopologyRecoveryFilter(TopologyRecoveryFilter topologyRecoveryFilter)
public TopologyRecoveryFilter getTopologyRecoveryFilter()
public void setConnectionRecoveryTriggeringCondition(Predicate<ShutdownSignalException> connectionRecoveryTriggeringCondition)
public Predicate<ShutdownSignalException> getConnectionRecoveryTriggeringCondition()
public void setTopologyRecoveryRetryHandler(RetryHandler topologyRecoveryRetryHandler)
public RetryHandler getTopologyRecoveryRetryHandler()
public void setRecoveredQueueNameSupplier(RecoveredQueueNameSupplier recoveredQueueNameSupplier)
public RecoveredQueueNameSupplier getRecoveredQueueNameSupplier()
public void setTrafficListener(TrafficListener trafficListener)
public TrafficListener getTrafficListener()
public void setCredentialsRefreshService(CredentialsRefreshService credentialsRefreshService)
public CredentialsRefreshService getCredentialsRefreshService()
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.