reactor.rabbitmq

Class ChannelPoolOptions

java.lang.Object

reactor.rabbitmq.ChannelPoolOptions

public class ChannelPoolOptions
extends Object

Options to when creating a ChannelPool.

Since:

1.1.0

See Also:

ChannelPoolFactory, LazyChannelPool

Constructor Summary

Constructors

Constructor and Description
ChannelPoolOptions()

Method Summary

Modifier and Type	Method and Description
Integer	getMaxCacheSize()
Scheduler	getSubscriptionScheduler()
ChannelPoolOptions	maxCacheSize(int maxCacheSize) Set the maximum size of the pool.
ChannelPoolOptions	subscriptionScheduler(Scheduler subscriptionScheduler) Set the scheduler to use when opening Channels.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelPoolOptions

public ChannelPoolOptions()

Method Detail

maxCacheSize

public ChannelPoolOptions maxCacheSize(int maxCacheSize)

Set the maximum size of the pool.

Default is 5 channels.

Parameters:

maxCacheSize -

Returns:

this ChannelPoolOptions instance

getMaxCacheSize

@Nullable
public Integer getMaxCacheSize()

subscriptionScheduler

public ChannelPoolOptions subscriptionScheduler(@Nullable
                                                Scheduler subscriptionScheduler)

Set the scheduler to use when opening Channels.

Parameters:

subscriptionScheduler -

Returns:

this ChannelPoolOptions instance

getSubscriptionScheduler

@Nullable
public Scheduler getSubscriptionScheduler()