org.apache.qpid.proton.engine.impl

Class TransportImpl

java.lang.Object

org.apache.qpid.proton.engine.impl.EndpointImpl

org.apache.qpid.proton.engine.impl.TransportImpl

All Implemented Interfaces:

FrameBody.FrameBodyHandler<java.lang.Integer>, Endpoint, FrameHandler, ProtonJEndpoint, ProtonJTransport, Transport

public class TransportImpl
extends EndpointImpl
implements ProtonJTransport, FrameBody.FrameBodyHandler<java.lang.Integer>, FrameHandler

Field Summary

Fields inherited from interface org.apache.qpid.proton.engine.Transport

DEFAULT_MAX_FRAME_SIZE, END_OF_STREAM, MIN_MAX_FRAME_SIZE, SESSION_WINDOW

Constructor Summary

Constructors

Constructor and Description
TransportImpl() Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a EngineFactory instead

Method Summary

Methods

Modifier and Type	Method and Description
void	bind(Connection conn)
int	capacity()
void	close_head()
void	close_tail()
void	closed()
void	free()
protected ConnectionImpl	getConnectionImpl()
java.nio.ByteBuffer	getInputBuffer()
int	getMaxFrameSize()
java.nio.ByteBuffer	getOutputBuffer()
ProtocolTracer	getProtocolTracer()
int	getRemoteMaxFrameSize()
void	handleAttach(Attach attach, Binary payload, java.lang.Integer channel)
void	handleBegin(Begin begin, Binary payload, java.lang.Integer channel)
void	handleClose(Close close, Binary payload, java.lang.Integer channel)
void	handleDetach(Detach detach, Binary payload, java.lang.Integer channel)
void	handleDisposition(Disposition disposition, Binary payload, java.lang.Integer channel)
void	handleEnd(End end, Binary payload, java.lang.Integer channel)
void	handleFlow(Flow flow, Binary payload, java.lang.Integer channel)
boolean	handleFrame(TransportFrame frame)
void	handleOpen(Open open, Binary payload, java.lang.Integer channel)
void	handleTransfer(Transfer transfer, Binary payload, java.lang.Integer channel)
java.nio.ByteBuffer	head()
int	input(byte[] bytes, int offset, int length)
boolean	isHandlingFrames() Returns whether I am currently able to handle frames.
TransportResult	oldApiCheckStateBeforeInput(int inputLength) This method is public as it is used by Python layer.
int	output(byte[] bytes, int offset, int size)
void	outputConsumed()
int	pending()
void	pop(int bytes)
void	process()
TransportResult	processInput()
Sasl	sasl()
void	setFrameHandler(FrameHandler frameHandler) Override the default frame handler.
void	setMaxFrameSize(int maxFrameSize) TODO propagate the new value to _outputProcessor etc
void	setProtocolTracer(ProtocolTracer protocolTracer)
Ssl	ssl(SslDomain sslDomain)
Ssl	ssl(SslDomain sslDomain, SslPeerDetails sslPeerDetails)
java.nio.ByteBuffer	tail()
java.lang.String	toString()
boolean	writeInto(java.nio.ByteBuffer outputBuffer) Writes my pending output bytes into outputBuffer.

Methods inherited from class org.apache.qpid.proton.engine.impl.EndpointImpl

close, getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, setContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.proton.engine.Endpoint

close, getCondition, getContext, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, setContext

Constructor Detail

TransportImpl

@Deprecated
public TransportImpl()

Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a EngineFactory instead

Method Detail

getMaxFrameSize

public int getMaxFrameSize()

Specified by:

getMaxFrameSize in interface Transport

getRemoteMaxFrameSize

public int getRemoteMaxFrameSize()

Specified by:

getRemoteMaxFrameSize in interface Transport

setMaxFrameSize

public void setMaxFrameSize(int maxFrameSize)

TODO propagate the new value to _outputProcessor etc

Specified by:

setMaxFrameSize in interface Transport

bind

public void bind(Connection conn)

Specified by:

bind in interface Transport

input

public int input(byte[] bytes,
        int offset,
        int length)

Specified by:

input in interface Transport

oldApiCheckStateBeforeInput

public TransportResult oldApiCheckStateBeforeInput(int inputLength)

This method is public as it is used by Python layer.

See Also:

Transport.input(byte[], int, int)

output

public int output(byte[] bytes,
         int offset,
         int size)

Specified by:

output in interface Transport

writeInto

public boolean writeInto(java.nio.ByteBuffer outputBuffer)

Writes my pending output bytes into outputBuffer. Does not subsequently flip it. Returns true on end of stream.

sasl

public Sasl sasl()

Specified by:

sasl in interface Transport

ssl

public Ssl ssl(SslDomain sslDomain,
      SslPeerDetails sslPeerDetails)

Note that sslDomain must implement ProtonSslEngineProvider. This is not possible enforce at the API level because ProtonSslEngineProvider is not part of the public Proton API.

Specified by:

ssl in interface Transport

ssl

public Ssl ssl(SslDomain sslDomain)

Specified by:

ssl in interface Transport

getConnectionImpl

protected ConnectionImpl getConnectionImpl()

Specified by:

getConnectionImpl in class EndpointImpl

free

public void free()

Specified by:

free in interface Endpoint

Overrides:

free in class EndpointImpl

handleOpen

public void handleOpen(Open open,
              Binary payload,
              java.lang.Integer channel)

Specified by:

handleOpen in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleBegin

public void handleBegin(Begin begin,
               Binary payload,
               java.lang.Integer channel)

Specified by:

handleBegin in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleAttach

public void handleAttach(Attach attach,
                Binary payload,
                java.lang.Integer channel)

Specified by:

handleAttach in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleFlow

public void handleFlow(Flow flow,
              Binary payload,
              java.lang.Integer channel)

Specified by:

handleFlow in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleTransfer

public void handleTransfer(Transfer transfer,
                  Binary payload,
                  java.lang.Integer channel)

Specified by:

handleTransfer in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleDisposition

public void handleDisposition(Disposition disposition,
                     Binary payload,
                     java.lang.Integer channel)

Specified by:

handleDisposition in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleDetach

public void handleDetach(Detach detach,
                Binary payload,
                java.lang.Integer channel)

Specified by:

handleDetach in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleEnd

public void handleEnd(End end,
             Binary payload,
             java.lang.Integer channel)

Specified by:

handleEnd in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleClose

public void handleClose(Close close,
               Binary payload,
               java.lang.Integer channel)

Specified by:

handleClose in interface FrameBody.FrameBodyHandler<java.lang.Integer>

handleFrame

public boolean handleFrame(TransportFrame frame)

Specified by:

handleFrame in interface FrameHandler

See Also:

FrameHandler.isHandlingFrames()

closed

public void closed()

Specified by:

closed in interface FrameHandler

isHandlingFrames

public boolean isHandlingFrames()

Description copied from interface: FrameHandler

Returns whether I am currently able to handle frames. MUST be checked before calling FrameHandler.handleFrame(TransportFrame).

Specified by:

isHandlingFrames in interface FrameHandler

getProtocolTracer

public ProtocolTracer getProtocolTracer()

Specified by:

getProtocolTracer in interface ProtonJTransport

setProtocolTracer

public void setProtocolTracer(ProtocolTracer protocolTracer)

Specified by:

setProtocolTracer in interface ProtonJTransport

getInputBuffer

public java.nio.ByteBuffer getInputBuffer()

Specified by:

getInputBuffer in interface Transport

processInput

public TransportResult processInput()

Specified by:

processInput in interface Transport

getOutputBuffer

public java.nio.ByteBuffer getOutputBuffer()

Specified by:

getOutputBuffer in interface Transport

outputConsumed

public void outputConsumed()

Specified by:

outputConsumed in interface Transport

capacity

public int capacity()

Specified by:

capacity in interface Transport

tail

public java.nio.ByteBuffer tail()

Specified by:

tail in interface Transport

process

public void process()
             throws TransportException

Specified by:

process in interface Transport

Throws:

TransportException

close_tail

public void close_tail()

Specified by:

close_tail in interface Transport

pending

public int pending()

Specified by:

pending in interface Transport

head

public java.nio.ByteBuffer head()

Specified by:

head in interface Transport

pop

public void pop(int bytes)

Specified by:

pop in interface Transport

close_head

public void close_head()

Specified by:

close_head in interface Transport

toString

public java.lang.String toString()

Overrides:

toString in class EndpointImpl

setFrameHandler

public void setFrameHandler(FrameHandler frameHandler)

Override the default frame handler. Must be called before the transport starts being used (e.g. getInputBuffer(), getOutputBuffer(), ssl(SslDomain) etc).