public class AmqpSender extends AmqpAbstractLink<org.apache.qpid.proton.engine.Sender>
closeActions, closed, endpoint, opened, session
Constructor and Description |
---|
AmqpSender(AmqpSession session,
org.apache.qpid.proton.engine.Sender endpoint,
ConsumerInfo consumerInfo)
Creates a new AmqpSender instance that manages the given Sender
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Request from the remote peer to close this resource.
|
void |
commit(LocalTransactionId txnId)
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.
|
ConsumerId |
getConsumerId() |
ActiveMQDestination |
getDestination() |
void |
onConsumerControl(ConsumerControl control)
Called when the Broker sends a ConsumerControl command to the Consumer that
this sender creates to obtain messages to dispatch via the sender for this
end of the open link.
|
void |
onMessageDispatch(MessageDispatch dispatch)
Event point for incoming message from ActiveMQ on this Sender's
corresponding subscription.
|
void |
open()
Request from the remote peer to open this resource.
|
void |
pumpOutbound() |
void |
rollback(LocalTransactionId txnId)
Handle work necessary on rollback of transacted resources associated with
this Link instance.
|
void |
setDestination(ActiveMQDestination destination)
Sets the ActiveMQDestination that this link will be servicing.
|
String |
toString() |
addCloseAction, close, getEndpoint, getSession, isClosed, isOpened, sendToActiveMQ, sendToActiveMQ
public AmqpSender(AmqpSession session, org.apache.qpid.proton.engine.Sender endpoint, ConsumerInfo consumerInfo)
session
- the AmqpSession object that is the parent of this instance.endpoint
- the AMQP Sender instance that this class manages.consumerInfo
- the ConsumerInfo instance that holds configuration for this sender.public void open()
AmqpResource
open
in interface AmqpResource
open
in class AmqpAbstractLink<org.apache.qpid.proton.engine.Sender>
public void detach()
AmqpLink
detach
in interface AmqpLink
detach
in class AmqpAbstractLink<org.apache.qpid.proton.engine.Sender>
public void close()
AmqpResource
close
in interface AmqpResource
close
in class AmqpAbstractLink<org.apache.qpid.proton.engine.Sender>
public void flow() throws Exception
AmqpLink
Exception
public void delivery(org.apache.qpid.proton.engine.Delivery delivery) throws Exception
AmqpLink
delivery
- the newly arrived delivery on this link.Exception
- if an error occurs while processing the new Delivery.public void commit(LocalTransactionId txnId) throws Exception
AmqpLink
txnId
- The Transaction ID being committed.Exception
- if an error occurs while performing the commit.public void rollback(LocalTransactionId txnId) throws Exception
AmqpLink
txnId
- The Transaction ID being rolled back.Exception
- if an error occurs while performing the rollback.public void onMessageDispatch(MessageDispatch dispatch) throws Exception
dispatch
- the MessageDispatch to process and send across the link.Exception
- if an error occurs while encoding the message for send.public void onConsumerControl(ConsumerControl control)
control
- The ConsumerControl command to process.public ConsumerId getConsumerId()
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
AmqpLink
destination
- the ActiveMQDestination that this link services.public void pumpOutbound() throws Exception
Exception
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.