org.eclipse.jetty.server

Class LocalConnector

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.server.AbstractConnector

org.eclipse.jetty.server.LocalConnector

All Implemented Interfaces:

Connector, Container, Destroyable, Dumpable, Graceful, LifeCycle

public class LocalConnector
extends AbstractConnector

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	LocalConnector.LocalEndPoint

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

Container.InheritedListener, Container.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.server.AbstractConnector

LOG

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
LocalConnector(Server server)
LocalConnector(Server server, ConnectionFactory connectionFactory)
LocalConnector(Server server, ConnectionFactory connectionFactory, SslContextFactory sslContextFactory)
LocalConnector(Server server, Executor executor, Scheduler scheduler, ByteBufferPool pool, int acceptors, ConnectionFactory... factories)
LocalConnector(Server server, SslContextFactory sslContextFactory)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	accept(int acceptorID)
LocalConnector.LocalEndPoint	executeRequest(String rawRequest) Execute a request and return the EndPoint through which responses can be received.
ByteBuffer	getResponses(ByteBuffer requestsBuffer) Sends requests and get's responses based on thread activity.
ByteBuffer	getResponses(ByteBuffer requestsBuffer, long idleFor, TimeUnit units) Sends requests and get's responses based on thread activity.
String	getResponses(String requests) Sends requests and get responses based on thread activity.
String	getResponses(String requests, long idleFor, TimeUnit units) Sends requests and get responses based on thread activity.
Object	getTransport()

Methods inherited from class org.eclipse.jetty.server.AbstractConnector

addConnectionFactory, clearConnectionFactories, doStart, doStop, getAcceptorPriorityDelta, getAcceptors, getByteBufferPool, getConnectedEndPoints, getConnectionFactories, getConnectionFactory, getConnectionFactory, getDefaultConnectionFactory, getDefaultProtocol, getExecutor, getIdleTimeout, getName, getProtocols, getScheduler, getServer, interruptAcceptors, isAccepting, join, join, onEndPointClosed, onEndPointOpened, removeConnectionFactory, setAcceptorPriorityDelta, setConnectionFactories, setDefaultProtocol, setIdleTimeout, setName, shutdown, toString

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

addBean, addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, 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.LifeCycle

addLifeCycleListener, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dump

Constructor Detail

LocalConnector

public LocalConnector(Server server,
              Executor executor,
              Scheduler scheduler,
              ByteBufferPool pool,
              int acceptors,
              ConnectionFactory... factories)

LocalConnector

public LocalConnector(Server server)

LocalConnector

public LocalConnector(Server server,
              SslContextFactory sslContextFactory)

LocalConnector

public LocalConnector(Server server,
              ConnectionFactory connectionFactory)

LocalConnector

public LocalConnector(Server server,
              ConnectionFactory connectionFactory,
              SslContextFactory sslContextFactory)

Method Detail

getTransport

public Object getTransport()

Returns:

the underlying socket, channel, buffer etc. for the connector.

getResponses

public String getResponses(String requests)
                    throws Exception

Sends requests and get responses based on thread activity. Returns all the responses received once the thread activity has returned to the level it was before the requests.

This methods waits until the connection is closed or is idle for 1s before returning the responses.

Parameters:

requests - the requests

Returns:

the responses

Throws:

Exception - if the requests fail

getResponses

public String getResponses(String requests,
                  long idleFor,
                  TimeUnit units)
                    throws Exception

Sends requests and get responses based on thread activity. Returns all the responses received once the thread activity has returned to the level it was before the requests.

This methods waits until the connection is closed or an idle period before returning the responses.

Parameters:

requests - the requests

idleFor - The time the response stream must be idle for before returning

units - The units of idleFor

Returns:

the responses

Throws:

Exception - if the requests fail

getResponses

public ByteBuffer getResponses(ByteBuffer requestsBuffer)
                        throws Exception

Sends requests and get's responses based on thread activity. Returns all the responses received once the thread activity has returned to the level it was before the requests.

This methods waits until the connection is closed or is idle for 1s before returning the responses.

Parameters:

requestsBuffer - the requests

Returns:

the responses

Throws:

Exception - if the requests fail

getResponses

public ByteBuffer getResponses(ByteBuffer requestsBuffer,
                      long idleFor,
                      TimeUnit units)
                        throws Exception

Sends requests and get's responses based on thread activity. Returns all the responses received once the thread activity has returned to the level it was before the requests.

This methods waits until the connection is closed or an idle period before returning the responses.

Parameters:

requestsBuffer - the requests

idleFor - The time the response stream must be idle for before returning

units - The units of idleFor

Returns:

the responses

Throws:

Exception - if the requests fail

executeRequest

public LocalConnector.LocalEndPoint executeRequest(String rawRequest)

Execute a request and return the EndPoint through which responses can be received.

Parameters:

rawRequest - the request

Returns:

the local endpoint

accept

protected void accept(int acceptorID)
               throws IOException,
                      InterruptedException

Specified by:

accept in class AbstractConnector

Throws:

IOException

InterruptedException