public class ContainerTransportProcessor extends Object implements TransportProcessor
ContainerProcessor
object is used to create
channels which can be used to consume and process requests. This
is basically an adapter to the Selector
which will
convert the provided transport to a usable channel. Each of the
connected pipelines will end up at this object, regardless of
whether those connections are SSL or plain data.Constructor and Description |
---|
ContainerTransportProcessor(Container container,
Allocator allocator,
int count)
Constructor for the
ContainerProcessor object. |
ContainerTransportProcessor(Container container,
Allocator allocator,
int count,
int select)
Constructor for the
ContainerProcessor object. |
Modifier and Type | Method and Description |
---|---|
void |
process(Transport transport)
This is used to consume HTTP messages that arrive on the given
transport.
|
void |
stop()
This method is used to stop the connector in such a way that it
will not accept and process any further messages.
|
public ContainerTransportProcessor(Container container, Allocator allocator, int count) throws IOException
ContainerProcessor
object.
This is used to create a processor which will convert the
provided transport objects to channels, which can then be
processed by the controller and dispatched to the container.container
- the container to dispatch requests toallocator
- this is the allocator used to buffer datacount
- this is the number of threads to be usedIOException
public ContainerTransportProcessor(Container container, Allocator allocator, int count, int select) throws IOException
ContainerProcessor
object.
This is used to create a processor which will convert the
provided transport objects to channels, which can then be
processed by the controller and dispatched to the container.container
- the container to dispatch requests toallocator
- this is the allocator used to buffer datacount
- this is the number of threads to be usedselect
- this is the number of controller threads to useIOException
public void process(Transport transport) throws IOException
Container
for processing. The response
will also be delivered over the provided transport. At this point
the SSL handshake will have fully completed.process
in interface TransportProcessor
transport
- the transport to process requests fromIOException
public void stop() throws IOException
stop
in interface TransportProcessor
IOException
Copyright © 2021. All rights reserved.