public interface ProtocolEngine extends TransportActivity
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() |
getLastReadTime, getLastWriteTime
void closed()
void writerIdle()
writerIdle
in interface TransportActivity
void readerIdle()
readerIdle
in interface TransportActivity
Subject getSubject()
boolean isTransportBlockedForWriting()
void setTransportBlockedForWriting(boolean blocked)
void setMessageAssignmentSuspended(boolean value, boolean notifyConsumers)
boolean isMessageAssignmentSuspended()
boolean hasWork()
void clearWork()
void notifyWork()
void setWorkListener(Action<ProtocolEngine> listener)
AggregateTicker getAggregateTicker()
void encryptedTransport()
void received(QpidByteBuffer msg)
void setIOThread(Thread ioThread)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.