public class AjpClientChannel extends AbstractFramedChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>
| Constructor and Description |
|---|
AjpClientChannel(org.xnio.StreamConnection connectedStreamChannel, ByteBufferPool bufferPool, org.xnio.OptionMap settings) Create a new AbstractFramedChannel 8 |
| Modifier and Type | Method and Description |
|---|---|
protected void | closeSubChannels() Method that is called when the channel is being forcibly closed, and all sub stream sink/source channels should also be forcibly closed. |
protected AbstractAjpClientStreamSourceChannel | createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) Method that creates the actual stream source channel implementation that is in use. |
protected void | handleBrokenSinkChannel(Throwable e) Method that is invoked when then write side of a channel is broken. |
protected void | handleBrokenSourceChannel(Throwable e) Method that is invoked when the read side of the channel is broken. |
protected boolean | isLastFrameReceived() Returns true if the protocol specific final frame has been received. |
protected boolean | isLastFrameSent() |
boolean | isOpen() |
protected void | lastDataRead() Method than is invoked when read() returns -1. |
protected FrameHeaderData | parseFrame(ByteBuffer data) Attempts to parse an incoming frame header from the data in the buffer. |
protected void | recalculateHeldFrames() |
AjpClientRequestClientStreamSinkChannel | sendRequest(HttpString method, String path, HttpString protocol, HeaderMap headers, Attachable attachable, org.xnio.ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener) |
addCloseTask, close, createIdleTimeoutChannel, flushSenders, getBufferPool, getCloseSetter, getDestinationAddress, getFramePriority, getIdleTimeout, getIoThread, getLocalAddress, getLocalAddress, getOption, getPeerAddress, getPeerAddress, getReceiveSetter, getSourceAddress, getUnderlyingConnection, getWorker, isReadsBroken, isReceivesResumed, isWritesBroken, markReadsBroken, markWritesBroken, queueFrame, receive, resumeReceives, setIdleTimeout, setOption, supportsOption, suspendReceives, toString, writeExceptionHandlerpublic AjpClientChannel(org.xnio.StreamConnection connectedStreamChannel,
ByteBufferPool bufferPool,
org.xnio.OptionMap settings) AbstractFramedChannel 8connectedStreamChannel - The ConnectedStreamChannel over which the WebSocket Frames should get send and received. Be aware that it already must be "upgraded".bufferPool - The Pool which will be used to acquire ByteBuffer's from.protected AbstractAjpClientStreamSourceChannel createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) throws IOException
AbstractFramedChannelcreateChannel in class AbstractFramedChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>frameHeaderData - The header data, as returned by AbstractFramedChannel.parseFrame(java.nio.ByteBuffer)frameData - Any additional data for the frame that has already been read. This may not be the complete frame contentsIOExceptionprotected FrameHeaderData parseFrame(ByteBuffer data) throws IOException
AbstractFramedChannelparseFrame in class AbstractFramedChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>data - The data that has been read from the channelnull if the data was incompleteIOException - If the data could not be parsed.public AjpClientRequestClientStreamSinkChannel sendRequest(HttpString method, String path, HttpString protocol, HeaderMap headers, Attachable attachable, org.xnio.ChannelListener<AjpClientRequestClientStreamSinkChannel> finishListener)
protected boolean isLastFrameReceived()
AbstractFramedChannelisLastFrameReceived in class AbstractFramedChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>true If the last frame has been receivedprotected boolean isLastFrameSent()
isLastFrameSent in class AbstractFramedChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>true If the last frame has been sentprotected void lastDataRead()
AbstractFramedChannelprotected void handleBrokenSourceChannel(Throwable e)
AbstractFramedChannelprotected void handleBrokenSinkChannel(Throwable e)
AbstractFramedChannelprotected void closeSubChannels()
AbstractFramedChannelpublic boolean isOpen()
isOpen in interface ChannelisOpen in class AbstractFramedChannel<AjpClientChannel,AbstractAjpClientStreamSourceChannel,AbstractAjpClientStreamSinkChannel>protected void recalculateHeldFrames()
throws IOException Copyright © 2015 JBoss by Red Hat. All rights reserved.