public interface AmqpLink extends AmqpResource
Modifier and Type | Method and Description |
---|---|
void |
addCloseAction(Runnable action)
Adds a new Runnable that is called on close of this link.
|
void |
close(org.apache.qpid.proton.amqp.transport.ErrorCondition error)
Close the Link with an error indicating the reson for the close.
|
void |
commit()
Handle work necessary on commit of transacted resources associated with
this Link instance.
|
void |
delivery(org.apache.qpid.proton.engine.Delivery delivery)
Called when a new Delivery arrives for the given Link.
|
void |
detach()
Request from the remote peer to detach this resource.
|
void |
flow()
Handles an incoming flow control.
|
org.apache.activemq.command.ActiveMQDestination |
getDestination() |
void |
rollback()
Handle work necessary on rollback of transacted resources associated with
this Link instance.
|
void |
setDestination(org.apache.activemq.command.ActiveMQDestination destination)
Sets the ActiveMQDestination that this link will be servicing.
|
close, open
void close(org.apache.qpid.proton.amqp.transport.ErrorCondition error)
error
- the error that prompted the close.void detach()
void flow() throws Exception
Excption
- if an error occurs during the flow processing.Exception
void delivery(org.apache.qpid.proton.engine.Delivery delivery) throws Exception
delivery
- the newly arrived delivery on this link.Exception
- if an error occurs while processing the new Delivery.void commit() throws Exception
Exception
- if an error occurs while performing the commit.void rollback() throws Exception
Exception
- if an error occurs while performing the rollback.org.apache.activemq.command.ActiveMQDestination getDestination()
void setDestination(org.apache.activemq.command.ActiveMQDestination destination)
destination
- the ActiveMQDestination that this link services.void addCloseAction(Runnable action)
action
- a Runnable that will be executed when the link closes or detaches.Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.