public interface ProtonHandler
ProtonHandlerImpl
Modifier and Type | Interface and Description |
---|---|
static class |
ProtonHandler.Factory |
Modifier and Type | Method and Description |
---|---|
ProtonHandler |
addEventHandler(EventHandler handler)
Add an event handler to the chain
|
int |
capacity()
It returns true if the transport connection has any capacity available
|
boolean |
checkDataReceived()
To be used at your discretion to verify if the client was active since you last checked
it can be used to implement server TTL cleanup and verifications
|
void |
close()
It will close the connection and flush events
|
void |
createClientSasl(ClientSASL clientSASL) |
void |
createServerSASL(ServerSASL[] handlers)
To be used on server connections.
|
void |
flush()
It will process the transport and cause events to be called
|
org.apache.qpid.proton.engine.Connection |
getConnection() |
long |
getCreationTime()
Return the creation time of the handler
|
Object |
getLock()
Get the object used to lock transport, connection and events operations
|
SASLResult |
getSASLResult()
To return the SASL Mechanism that was successful with the connection.
|
org.apache.qpid.proton.engine.Transport |
getTransport() |
void |
inputBuffer(io.netty.buffer.ByteBuf buffer)
The input on the Handler.
|
io.netty.buffer.ByteBuf |
outputBuffer()
it will return pending bytes you have on the Transport
after you are done with it you must call
outputDone(int) |
void |
outputDone(int bytes)
To be called after you used the outputBuffer
|
long |
tick(boolean firstTick) |
long tick(boolean firstTick)
int capacity()
org.apache.qpid.proton.engine.Transport getTransport()
org.apache.qpid.proton.engine.Connection getConnection()
ProtonHandler addEventHandler(EventHandler handler)
handler
- void createClientSasl(ClientSASL clientSASL)
void createServerSASL(ServerSASL[] handlers)
handlers
- SASLResult getSASLResult()
void inputBuffer(io.netty.buffer.ByteBuf buffer)
buffer
- boolean checkDataReceived()
long getCreationTime()
void outputDone(int bytes)
bytes
- number of bytes you used already on the outputio.netty.buffer.ByteBuf outputBuffer()
outputDone(int)
void flush()
void close()
Object getLock()
Copyright © 2016 The Apache Software Foundation. All rights reserved.