Package org.eclipse.jetty.client
Class MultiplexConnectionPool
java.lang.Object
org.eclipse.jetty.util.component.AbstractLifeCycle
org.eclipse.jetty.util.component.ContainerLifeCycle
org.eclipse.jetty.client.AbstractConnectionPool
org.eclipse.jetty.client.MultiplexConnectionPool
- All Implemented Interfaces:
ConnectionPool
,Container
,Destroyable
,Dumpable
,Dumpable.DumpableContainer
,LifeCycle
,Sweeper.Sweepable
- Direct Known Subclasses:
RandomConnectionPool
,RoundRobinConnectionPool
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException
Nested classes/interfaces inherited from interface org.eclipse.jetty.client.ConnectionPool
ConnectionPool.Factory, ConnectionPool.MaxMultiplexable, ConnectionPool.MaxUsable
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container
Container.InheritedListener, Container.Listener
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
Dumpable.DumpableContainer
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle
LifeCycle.Listener
-
Field Summary
-
Constructor Summary
ModifierConstructorDescriptionMultiplexConnectionPool
(Destination destination, int maxConnections, int initialMaxMultiplex) protected
MultiplexConnectionPool
(Destination destination, Pool.Factory<Connection> poolFactory, int initialMaxMultiplex) -
Method Summary
Modifier and TypeMethodDescriptionint
static ToIntFunction<Connection>
newMaxMultiplexer
(int defaultMaxMultiplex) Returns a function that computes the max multiplex value for a givenConnection
, if possible, otherwise returns the givendefaultMaxMultiplex
value.void
setInitialMaxMultiplex
(int initialMaxMultiplex) Methods inherited from class org.eclipse.jetty.client.AbstractConnectionPool
accept, acquire, acquired, activate, deactivate, doStart, doStop, dump, getActiveConnectionCount, getConnectionCount, getIdleConnectionCount, getMaxConnectionCount, getMaxDuration, getMaxUsage, getPendingConnectionCount, idle, isActive, isEmpty, isMaximizeConnections, onCreated, onRemoved, preCreateConnections, proceed, release, released, remove, removed, setMaxDuration, setMaximizeConnections, setMaxUsage, sweep, toString, tryCreate
Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle
addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, installBean, installBean, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.eclipse.jetty.util.component.Container
getCachedBeans, getEventListeners
Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer
isDumpable
-
Constructor Details
-
MultiplexConnectionPool
public MultiplexConnectionPool(Destination destination, int maxConnections, int initialMaxMultiplex) -
MultiplexConnectionPool
protected MultiplexConnectionPool(Destination destination, Pool.Factory<Connection> poolFactory, int initialMaxMultiplex)
-
-
Method Details
-
newMaxMultiplexer
Returns a function that computes the max multiplex value for a given
Connection
, if possible, otherwise returns the givendefaultMaxMultiplex
value.- Parameters:
defaultMaxMultiplex
- the default max multiplex value- Returns:
- a function that computes the max multiplex value for a connection
-
getInitialMaxMultiplex
@ManagedAttribute("The initial multiplexing factor of connections") public int getInitialMaxMultiplex()- Overrides:
getInitialMaxMultiplex
in classAbstractConnectionPool
-
setInitialMaxMultiplex
public void setInitialMaxMultiplex(int initialMaxMultiplex) - Overrides:
setInitialMaxMultiplex
in classAbstractConnectionPool
-