org.apache.qpid.server.transport

Interface ProtocolEngine

All Superinterfaces:

TransportActivity

All Known Implementing Classes:

AbstractAMQPConnection, AMQPConnection_0_10, AMQPConnection_0_8, AMQPConnection_1_0, MultiVersionProtocolEngine

public interface ProtocolEngine
extends TransportActivity

A ProtocolEngine is a Receiver for java.nio.ByteBuffers. It takes the data passed to it in the received decodes it and then process the result.

Method Summary

Modifier and Type	Method and Description
void	clearWork()
void	closed()
void	encryptedTransport()
AggregateTicker	getAggregateTicker()
Subject	getSubject()
boolean	hasWork()
boolean	isMessageAssignmentSuspended()
boolean	isTransportBlockedForWriting()
void	notifyWork()
Iterator<Runnable>	processPendingIterator()
void	readerIdle()
void	received(QpidByteBuffer msg)
void	setIOThread(Thread ioThread)
void	setMessageAssignmentSuspended(boolean value, boolean notifyConsumers)
void	setTransportBlockedForWriting(boolean blocked)
void	setWorkListener(Action<ProtocolEngine> listener)
void	writerIdle()

Methods inherited from interface org.apache.qpid.transport.network.TransportActivity

getLastReadTime, getLastWriteTime

Method Detail

closed

void closed()

writerIdle

void writerIdle()

Specified by:

writerIdle in interface TransportActivity

readerIdle

void readerIdle()

Specified by:

readerIdle in interface TransportActivity

getSubject

Subject getSubject()

isTransportBlockedForWriting

boolean isTransportBlockedForWriting()

setTransportBlockedForWriting

void setTransportBlockedForWriting(boolean blocked)

setMessageAssignmentSuspended

void setMessageAssignmentSuspended(boolean value,
                                   boolean notifyConsumers)

isMessageAssignmentSuspended

boolean isMessageAssignmentSuspended()

processPendingIterator

Iterator<Runnable> processPendingIterator()

hasWork

boolean hasWork()

clearWork

void clearWork()

notifyWork

void notifyWork()

setWorkListener

void setWorkListener(Action<ProtocolEngine> listener)

getAggregateTicker

AggregateTicker getAggregateTicker()

encryptedTransport

void encryptedTransport()

received

void received(QpidByteBuffer msg)

setIOThread

void setIOThread(Thread ioThread)