org.apache.qpid.amqp_1_0.transport

Class ProtocolHeaderTransport

java.lang.Object

org.apache.qpid.amqp_1_0.transport.ProtocolHeaderTransport

All Implemented Interfaces:

BytesProcessor, BytesTransport

public class ProtocolHeaderTransport
extends Object
implements BytesTransport

Constructor Summary

Constructors

Constructor and Description
ProtocolHeaderTransport(Map<Binary,BytesTransport> validHeaders)

Method Summary

Modifier and Type	Method and Description
void	getNextBytes(BytesProcessor processor)
void	inputClosed()
boolean	isOpenForInput()
boolean	isOpenForOutput()
void	outputClosed()
void	processBytes(ByteBuffer buf)
void	setInputStateChangeListener(StateChangeListener listener)
void	setOutputStateChangeListener(StateChangeListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtocolHeaderTransport

public ProtocolHeaderTransport(Map<Binary,BytesTransport> validHeaders)

Method Detail

isOpenForInput

public boolean isOpenForInput()

Specified by:

isOpenForInput in interface BytesTransport

inputClosed

public void inputClosed()

Specified by:

inputClosed in interface BytesTransport

processBytes

public void processBytes(ByteBuffer buf)

Specified by:

processBytes in interface BytesProcessor

Specified by:

processBytes in interface BytesTransport

setInputStateChangeListener

public void setInputStateChangeListener(StateChangeListener listener)

Specified by:

setInputStateChangeListener in interface BytesTransport

getNextBytes

public void getNextBytes(BytesProcessor processor)

Specified by:

getNextBytes in interface BytesTransport

outputClosed

public void outputClosed()

Specified by:

outputClosed in interface BytesTransport

isOpenForOutput

public boolean isOpenForOutput()

Specified by:

isOpenForOutput in interface BytesTransport

setOutputStateChangeListener

public void setOutputStateChangeListener(StateChangeListener listener)

Specified by:

setOutputStateChangeListener in interface BytesTransport