public class AmqpReceiver extends AmqpAbstractReceiver
configuredCredit, current, recvBuffer
closeActions, closed, endpoint, opened, session
Constructor and Description |
---|
AmqpReceiver(AmqpSession session,
org.apache.qpid.proton.engine.Receiver endpoint,
ProducerInfo producerInfo)
Create a new instance of an AmqpReceiver
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Request from the remote peer to close this resource.
|
ActiveMQDestination |
getDestination() |
ProducerId |
getProducerId() |
protected InboundTransformer |
getTransformer() |
boolean |
isAnonymous()
If the Sender that initiated this Receiver endpoint did not define an address
then it is using anonymous mode and message are to be routed to the address
that is defined in the AMQP message 'To' field.
|
protected void |
processDelivery(org.apache.qpid.proton.engine.Delivery delivery,
org.fusesource.hawtbuf.Buffer deliveryBytes) |
void |
setDestination(ActiveMQDestination destination)
Sets the ActiveMQDestination that this link will be servicing.
|
commit, delivery, detach, flow, flow, getConfiguredReceiverCredit, rollback
addCloseAction, close, getEndpoint, getSession, isClosed, isOpened, open, sendToActiveMQ, sendToActiveMQ
public AmqpReceiver(AmqpSession session, org.apache.qpid.proton.engine.Receiver endpoint, ProducerInfo producerInfo)
session
- the Session that is the parent of this AmqpReceiver instance.endpoint
- the AMQP receiver endpoint that the class manages.producerInfo
- the ProducerInfo instance that contains this sender's configuration.public void close()
AmqpResource
close
in interface AmqpResource
close
in class AmqpAbstractLink<org.apache.qpid.proton.engine.Receiver>
public ProducerId getProducerId()
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
AmqpLink
destination
- the ActiveMQDestination that this link services.public boolean isAnonymous()
protected InboundTransformer getTransformer()
protected void processDelivery(org.apache.qpid.proton.engine.Delivery delivery, org.fusesource.hawtbuf.Buffer deliveryBytes) throws Exception
processDelivery
in class AmqpAbstractReceiver
Exception
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.