public interface ProtonLink<T extends ProtonLink<T>>
| Modifier and Type | Method and Description |
|---|---|
org.apache.qpid.proton.engine.Record |
attachments()
Retrieves the attachments record, upon which application items can be set/retrieved.
|
T |
close()
Closes the AMQP link, i.e.
|
T |
closeHandler(Handler<AsyncResult<T>> remoteCloseHandler)
Sets a handler for when an AMQP Detach frame is received from the remote peer.
|
org.apache.qpid.proton.amqp.transport.ErrorCondition |
getCondition()
Gets the local ErrorCondition object.
|
ProtonQoS |
getQoS()
Gets the local QOS config.
|
org.apache.qpid.proton.amqp.transport.ErrorCondition |
getRemoteCondition()
Gets the remote ErrorCondition object.
|
ProtonQoS |
getRemoteQoS()
Gets the remote QOS config.
|
org.apache.qpid.proton.amqp.transport.Source |
getRemoteSource()
Gets the current remote source config.
|
org.apache.qpid.proton.amqp.transport.Target |
getRemoteTarget()
Gets the current remote target config.
|
ProtonSession |
getSession()
Gets the session this link is on.
|
org.apache.qpid.proton.amqp.transport.Source |
getSource()
Gets the current local source config.
|
org.apache.qpid.proton.amqp.transport.Target |
getTarget()
Gets the current local target config.
|
boolean |
isOpen()
Check whether the link is locally open.
|
T |
open()
Opens the AMQP link, i.e.
|
T |
openHandler(Handler<AsyncResult<T>> remoteOpenHandler)
Sets a handler for when an AMQP Attach frame is received from the remote peer.
|
T |
setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
Sets the local ErrorCondition object.
|
T |
setQoS(ProtonQoS qos)
Sets the local QOS config.
|
T |
setSource(org.apache.qpid.proton.amqp.transport.Source source)
Sets the current local source config.
|
T |
setTarget(org.apache.qpid.proton.amqp.transport.Target target)
Sets the current local target config.
|
T open()
openHandler(Handler) may be used to handle the peer sending their Attach
frame.T close()
closeHandler(Handler) may be used to handle the peer
sending their Detach frame.T openHandler(Handler<AsyncResult<T>> remoteOpenHandler)
ProtonConnection.senderOpenHandler(Handler) and
ProtonConnection.receiverOpenHandler(Handler).remoteOpenHandler - the handlerT closeHandler(Handler<AsyncResult<T>> remoteCloseHandler)
remoteCloseHandler - the handlerProtonQoS getQoS()
T setQoS(ProtonQoS qos)
qos - the QOS to configureProtonQoS getRemoteQoS()
boolean isOpen()
org.apache.qpid.proton.engine.Record attachments()
org.apache.qpid.proton.amqp.transport.Target getTarget()
T setTarget(org.apache.qpid.proton.amqp.transport.Target target)
target - the targetorg.apache.qpid.proton.amqp.transport.Target getRemoteTarget()
org.apache.qpid.proton.amqp.transport.Source getSource()
T setSource(org.apache.qpid.proton.amqp.transport.Source source)
source - the sourceorg.apache.qpid.proton.amqp.transport.Source getRemoteSource()
ProtonSession getSession()
T setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
condition - the condition to setorg.apache.qpid.proton.amqp.transport.ErrorCondition getCondition()
org.apache.qpid.proton.amqp.transport.ErrorCondition getRemoteCondition()
Copyright © 2016. All rights reserved.