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:
Closeable
,AutoCloseable
,ConnectionPool
,ConnectionPool.Multiplexable
,Container
,Destroyable
,Dumpable
,Dumpable.DumpableContainer
,LifeCycle
,Sweeper.Sweepable
- Direct Known Subclasses:
RandomConnectionPool
,RoundRobinConnectionPool
@ManagedObject
public class MultiplexConnectionPool
extends AbstractConnectionPool
implements ConnectionPool.Multiplexable
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
AbstractLifeCycle.AbstractLifeCycleListener
Nested classes/interfaces inherited from interface org.eclipse.jetty.client.ConnectionPool
ConnectionPool.Factory, ConnectionPool.Multiplexable
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
ConstructorsConstructorDescriptionMultiplexConnectionPool
(HttpDestination destination, int maxConnections, boolean cache, Callback requester, int maxMultiplex) MultiplexConnectionPool
(HttpDestination destination, int maxConnections, Callback requester, int maxMultiplex) MultiplexConnectionPool
(HttpDestination destination, Pool<Connection> pool, Callback requester, int maxMultiplex) -
Method Summary
Modifier and TypeMethodDescriptionint
int
void
setMaxMultiplex
(int maxMultiplex) void
setMaxUsageCount
(int maxUsageCount) Methods inherited from class org.eclipse.jetty.client.AbstractConnectionPool
acquire, acquire, acquired, activate, close, deactivate, doStop, dump, getActiveConnectionCount, getActiveConnections, getConnectionCount, getIdleConnectionCount, getIdleConnections, getMaxConnectionCount, getMaxDuration, getPendingConnectionCount, getPendingCount, idle, isActive, isClosed, isEmpty, isMaximizeConnections, onCreated, preCreateConnections, proceed, release, released, remove, remove, removed, setMaxDuration, setMaximizeConnections, sweep, toString, tryCreate
Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle
addBean, addBean, addEventListener, addManaged, contains, destroy, doStart, dump, dump, dump, dump, dumpBeans, dumpObject, dumpObjects, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, 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.Dumpable.DumpableContainer
isDumpable
-
Constructor Details
-
MultiplexConnectionPool
public MultiplexConnectionPool(HttpDestination destination, int maxConnections, Callback requester, int maxMultiplex) -
MultiplexConnectionPool
public MultiplexConnectionPool(HttpDestination destination, int maxConnections, boolean cache, Callback requester, int maxMultiplex) -
MultiplexConnectionPool
public MultiplexConnectionPool(HttpDestination destination, Pool<Connection> pool, Callback requester, int maxMultiplex)
-
-
Method Details
-
getMaxMultiplex
- Specified by:
getMaxMultiplex
in interfaceConnectionPool.Multiplexable
- Overrides:
getMaxMultiplex
in classAbstractConnectionPool
- Returns:
- the max number of requests multiplexable on a single connection
-
setMaxMultiplex
public void setMaxMultiplex(int maxMultiplex) - Specified by:
setMaxMultiplex
in interfaceConnectionPool.Multiplexable
- Overrides:
setMaxMultiplex
in classAbstractConnectionPool
- Parameters:
maxMultiplex
- the max number of requests multiplexable on a single connection
-
getMaxUsageCount
@ManagedAttribute("The maximum amount of times a connection is used before it gets closed") public int getMaxUsageCount()- Overrides:
getMaxUsageCount
in classAbstractConnectionPool
-
setMaxUsageCount
public void setMaxUsageCount(int maxUsageCount) - Overrides:
setMaxUsageCount
in classAbstractConnectionPool
-