public class MultiVersionProtocolEngine extends Object implements ProtocolEngine
Constructor and Description |
---|
MultiVersionProtocolEngine(Broker<?> broker,
Set<Protocol> supported,
Protocol defaultSupportedReply,
AmqpPort<?> port,
Transport transport,
long id,
ProtocolEngineCreator[] creators,
Runnable onCloseTask) |
Modifier and Type | Method and Description |
---|---|
void |
clearWork() |
void |
closed() |
void |
encryptedTransport() |
AggregateTicker |
getAggregateTicker() |
long |
getConnectionId() |
long |
getLastReadTime() |
long |
getLastWriteTime() |
Subject |
getSubject() |
boolean |
hasWork() |
boolean |
isMessageAssignmentSuspended() |
boolean |
isProtocolEstablished() |
boolean |
isTransportBlockedForWriting() |
void |
notifyWork() |
Iterator<Runnable> |
processPendingIterator() |
void |
readerIdle() |
void |
received(QpidByteBuffer msg) |
void |
setIOThread(Thread ioThread) |
void |
setMessageAssignmentSuspended(boolean value,
boolean notifyConsumers) |
void |
setNetworkConnection(ServerNetworkConnection network) |
void |
setTransportBlockedForWriting(boolean blocked) |
void |
setWorkListener(Action<ProtocolEngine> listener) |
void |
writerIdle() |
public void setMessageAssignmentSuspended(boolean value, boolean notifyConsumers)
setMessageAssignmentSuspended
in interface ProtocolEngine
public boolean isMessageAssignmentSuspended()
isMessageAssignmentSuspended
in interface ProtocolEngine
public void closed()
closed
in interface ProtocolEngine
public void writerIdle()
writerIdle
in interface ProtocolEngine
writerIdle
in interface TransportActivity
public void readerIdle()
readerIdle
in interface ProtocolEngine
readerIdle
in interface TransportActivity
public void encryptedTransport()
encryptedTransport
in interface ProtocolEngine
public void received(QpidByteBuffer msg)
received
in interface ProtocolEngine
public void setIOThread(Thread ioThread)
setIOThread
in interface ProtocolEngine
public long getConnectionId()
public Subject getSubject()
getSubject
in interface ProtocolEngine
public boolean isTransportBlockedForWriting()
isTransportBlockedForWriting
in interface ProtocolEngine
public void setTransportBlockedForWriting(boolean blocked)
setTransportBlockedForWriting
in interface ProtocolEngine
public void setNetworkConnection(ServerNetworkConnection network)
public long getLastReadTime()
getLastReadTime
in interface TransportActivity
public long getLastWriteTime()
getLastWriteTime
in interface TransportActivity
public Iterator<Runnable> processPendingIterator()
processPendingIterator
in interface ProtocolEngine
public boolean hasWork()
hasWork
in interface ProtocolEngine
public void notifyWork()
notifyWork
in interface ProtocolEngine
public void setWorkListener(Action<ProtocolEngine> listener)
setWorkListener
in interface ProtocolEngine
public void clearWork()
clearWork
in interface ProtocolEngine
public AggregateTicker getAggregateTicker()
getAggregateTicker
in interface ProtocolEngine
public boolean isProtocolEstablished()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.