Class Client.ClientParameters

java.lang.Object

com.rabbitmq.stream.impl.Client.ClientParameters

Enclosing class:

Client

public static class Client.ClientParameters
extends Object

Constructor Summary

Constructors

Constructor	Description
ClientParameters()

Method Summary

Modifier and Type	Method	Description
Client.ClientParameters	bootstrapCustomizer(Consumer<Bootstrap> bootstrapCustomizer)
Client.ClientParameters	byteBufAllocator(ByteBufAllocator byteBufAllocator)
Client.ClientParameters	channelCustomizer(Consumer<Channel> channelCustomizer)
Client.ClientParameters	chunkChecksum(ChunkChecksum chunkChecksum)
Client.ClientParameters	chunkListener(Client.ChunkListener chunkListener)
Client.ClientParameters	clientProperties(Map<String,String> clientProperties)
Client.ClientParameters	clientProperty(String key, String value)
Client.ClientParameters	codec(Codec codec)
Client.ClientParameters	compressionCodecFactory(CompressionCodecFactory compressionCodecFactory)
Client.ClientParameters	consumerUpdateListener(Client.ConsumerUpdateListener consumerUpdateListener)
Client.ClientParameters	credentialsManager(CredentialsManager credentialsManager)
Client.ClientParameters	credentialsProvider(CredentialsProvider credentialsProvider)
Client.ClientParameters	creditNotification(Client.CreditNotification creditNotification)
Client.ClientParameters	dispatchingExecutorServiceFactory(com.rabbitmq.stream.impl.ExecutorServiceFactory dispatchingExecutorServiceFactory)
Client.ClientParameters	eventLoopGroup(EventLoopGroup eventLoopGroup)
Client.ClientParameters	executorServiceFactory(com.rabbitmq.stream.impl.ExecutorServiceFactory executorServiceFactory)
Client.ClientParameters	host(String host)
Client.ClientParameters	messageIgnoredListener(Client.MessageIgnoredListener messageIgnoredListener)
Client.ClientParameters	messageListener(Client.MessageListener messageListener)
Client.ClientParameters	metadataListener(Client.MetadataListener metadataListener)
Client.ClientParameters	metricsCollector(MetricsCollector metricsCollector)
Client.ClientParameters	password(String password)
Client.ClientParameters	port(int port)
Client.ClientParameters	publishConfirmListener(Client.PublishConfirmListener publishConfirmListener)
Client.ClientParameters	publishErrorListener(Client.PublishErrorListener publishErrorListener)
Client.ClientParameters	requestedHeartbeat(Duration requestedHeartbeat)
Client.ClientParameters	requestedMaxFrameSize(int requestedMaxFrameSize)
Client.ClientParameters	rpcTimeout(Duration rpcTimeout)
Client.ClientParameters	saslConfiguration(SaslConfiguration saslConfiguration)
Client.ClientParameters	shutdownListener(Client.ShutdownListener shutdownListener)
Client.ClientParameters	sslContext(SslContext sslContext)
Client.ClientParameters	username(String username)
Client.ClientParameters	virtualHost(String virtualHost)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ClientParameters

public ClientParameters()

Method Details

host

public Client.ClientParameters host(String host)

port

public Client.ClientParameters port(int port)

publishConfirmListener

public Client.ClientParameters publishConfirmListener(Client.PublishConfirmListener publishConfirmListener)

publishErrorListener

public Client.ClientParameters publishErrorListener(Client.PublishErrorListener publishErrorListener)

chunkListener

public Client.ClientParameters chunkListener(Client.ChunkListener chunkListener)

messageListener

public Client.ClientParameters messageListener(Client.MessageListener messageListener)

messageIgnoredListener

public Client.ClientParameters messageIgnoredListener(Client.MessageIgnoredListener messageIgnoredListener)

creditNotification

public Client.ClientParameters creditNotification(Client.CreditNotification creditNotification)

consumerUpdateListener

public Client.ClientParameters consumerUpdateListener(Client.ConsumerUpdateListener consumerUpdateListener)

codec

public Client.ClientParameters codec(Codec codec)

eventLoopGroup

public Client.ClientParameters eventLoopGroup(EventLoopGroup eventLoopGroup)

byteBufAllocator

public Client.ClientParameters byteBufAllocator(ByteBufAllocator byteBufAllocator)

saslConfiguration

public Client.ClientParameters saslConfiguration(SaslConfiguration saslConfiguration)

credentialsProvider

public Client.ClientParameters credentialsProvider(CredentialsProvider credentialsProvider)

credentialsManager

public Client.ClientParameters credentialsManager(CredentialsManager credentialsManager)

username

public Client.ClientParameters username(String username)

password

public Client.ClientParameters password(String password)

virtualHost

public Client.ClientParameters virtualHost(String virtualHost)

requestedHeartbeat

public Client.ClientParameters requestedHeartbeat(Duration requestedHeartbeat)

requestedMaxFrameSize

public Client.ClientParameters requestedMaxFrameSize(int requestedMaxFrameSize)

chunkChecksum

public Client.ClientParameters chunkChecksum(ChunkChecksum chunkChecksum)

clientProperties

public Client.ClientParameters clientProperties(Map<String,String> clientProperties)

clientProperty

public Client.ClientParameters clientProperty(String key,
 String value)

metricsCollector

public Client.ClientParameters metricsCollector(MetricsCollector metricsCollector)

metadataListener

public Client.ClientParameters metadataListener(Client.MetadataListener metadataListener)

shutdownListener

public Client.ClientParameters shutdownListener(Client.ShutdownListener shutdownListener)

sslContext

public Client.ClientParameters sslContext(SslContext sslContext)

compressionCodecFactory

public Client.ClientParameters compressionCodecFactory(CompressionCodecFactory compressionCodecFactory)

rpcTimeout

public Client.ClientParameters rpcTimeout(Duration rpcTimeout)

dispatchingExecutorServiceFactory

public Client.ClientParameters dispatchingExecutorServiceFactory(com.rabbitmq.stream.impl.ExecutorServiceFactory dispatchingExecutorServiceFactory)

executorServiceFactory

public Client.ClientParameters executorServiceFactory(com.rabbitmq.stream.impl.ExecutorServiceFactory executorServiceFactory)

channelCustomizer

public Client.ClientParameters channelCustomizer(Consumer<Channel> channelCustomizer)

bootstrapCustomizer

public Client.ClientParameters bootstrapCustomizer(Consumer<Bootstrap> bootstrapCustomizer)