org.mortbay.jetty.nio
Class BlockingChannelConnector
java.lang.Object
org.mortbay.component.AbstractLifeCycle
org.mortbay.jetty.AbstractBuffers
org.mortbay.jetty.AbstractConnector
org.mortbay.jetty.nio.AbstractNIOConnector
org.mortbay.jetty.nio.BlockingChannelConnector
- All Implemented Interfaces:
- org.mortbay.component.LifeCycle, Buffers, Connector, NIOConnector
public class BlockingChannelConnector
- extends AbstractNIOConnector
Blocking NIO connector.
This connector uses efficient NIO buffers with a traditional blocking thread model.
Direct NIO buffers are used and a thread is allocated per connections.
This connector is best used when there are a few very active connections.
- Author:
- gregw
Nested classes/interfaces inherited from interface org.mortbay.component.LifeCycle |
org.mortbay.component.LifeCycle.Listener |
Fields inherited from class org.mortbay.component.AbstractLifeCycle |
_listeners |
Methods inherited from class org.mortbay.jetty.AbstractConnector |
checkForwardedHeaders, configure, connectionClosed, connectionOpened, doStart, doStop, getAcceptorPriorityOffset, getAcceptors, getAcceptQueueSize, getConfidentialPort, getConfidentialScheme, getConnections, getConnectionsDurationAve, getConnectionsDurationMax, getConnectionsDurationMin, getConnectionsDurationTotal, getConnectionsOpen, getConnectionsOpenMax, getConnectionsOpenMin, getConnectionsRequestsAve, getConnectionsRequestsMax, getConnectionsRequestsMin, getForwardedForHeader, getForwardedHostHeader, getForwardedServerHeader, getHost, getHostHeader, getIntegralPort, getIntegralScheme, getLeftMostValue, getLowResourceMaxIdleTime, getMaxIdleTime, getName, getPort, getRequests, getResolveNames, getReuseAddress, getServer, getSoLingerTime, getStatsOn, getStatsOnMs, getThreadPool, isConfidential, isForwarded, isIntegral, join, newContinuation, persist, setAcceptorPriorityOffset, setAcceptors, setAcceptQueueSize, setConfidentialPort, setConfidentialScheme, setForwarded, setForwardedForHeader, setForwardedHostHeader, setForwardedServerHeader, setHost, setHostHeader, setIntegralPort, setIntegralScheme, setLowResourceMaxIdleTime, setMaxIdleTime, setName, setPort, setResolveNames, setReuseAddress, setServer, setSoLingerTime, setStatsOn, setThreadPool, statsReset, stopAccept, toString |
Methods inherited from class org.mortbay.component.AbstractLifeCycle |
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop |
Methods inherited from interface org.mortbay.component.LifeCycle |
addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop |
BlockingChannelConnector
public BlockingChannelConnector()
- Constructor.
getConnection
public Object getConnection()
- Returns:
- the underlying socket, channel, buffer etc. for the connector.
open
public void open()
throws IOException
- Description copied from interface:
Connector
- Opens the connector
- Throws:
IOException
close
public void close()
throws IOException
- Throws:
IOException
accept
public void accept(int acceptorID)
throws IOException,
InterruptedException
- Specified by:
accept
in class AbstractConnector
- Throws:
IOException
InterruptedException
customize
public void customize(EndPoint endpoint,
Request request)
throws IOException
- Description copied from interface:
Connector
- Customize a request for an endpoint.
Called on every request to allow customization of the request for
the particular endpoint (eg security properties from a SSL connection).
- Specified by:
customize
in interface Connector
- Overrides:
customize
in class AbstractConnector
- Throws:
IOException
getLocalPort
public int getLocalPort()
- Returns:
- The actual port the connector is listening on or -1 if there
is no port or the connector is not open.
Copyright © 2009 Mortbay Consulting Pty. Ltd. All Rights Reserved.