public class NonBlockingConnectionPlainDelegate extends Object
Constructor and Description |
---|
NonBlockingConnectionPlainDelegate(NonBlockingConnection parent,
AmqpPort<?> port) |
Modifier and Type | Method and Description |
---|---|
boolean |
doWrite(Collection<QpidByteBuffer> bufferArray) |
QpidByteBuffer |
getNetInputBuffer() |
Certificate |
getPeerCertificate() |
Principal |
getPeerPrincipal() |
String |
getTransportInfo() |
boolean |
needsWork() |
boolean |
processData() |
boolean |
readyForRead() |
protected void |
restoreApplicationBufferForWrite() |
void |
shutdownInput() |
void |
shutdownOutput() |
public NonBlockingConnectionPlainDelegate(NonBlockingConnection parent, AmqpPort<?> port)
public boolean readyForRead()
public boolean processData()
protected void restoreApplicationBufferForWrite()
public boolean doWrite(Collection<QpidByteBuffer> bufferArray) throws IOException
IOException
public Principal getPeerPrincipal()
public Certificate getPeerCertificate()
public boolean needsWork()
public QpidByteBuffer getNetInputBuffer()
public void shutdownInput()
public void shutdownOutput()
public String getTransportInfo()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.