public abstract class AbstractProtonReceiverContext extends ProtonInitializable implements ProtonDeliveryHandler
Modifier and Type | Field and Description |
---|---|
protected String |
address |
protected AbstractConnectionContext |
connection |
protected AbstractProtonSessionContext |
protonSession |
protected org.apache.qpid.proton.engine.Receiver |
receiver |
protected AMQPSessionCallback |
sessionSPI |
Constructor and Description |
---|
AbstractProtonReceiverContext(AMQPSessionCallback sessionSPI,
AbstractConnectionContext connection,
AbstractProtonSessionContext protonSession,
org.apache.qpid.proton.engine.Receiver receiver) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean remoteLinkClose) |
void |
close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
void |
drain(int credits) |
int |
drained() |
void |
flow(int credits,
int threshold) |
boolean |
isDraining() |
afterInit, initialise, isInitialized, waitWithTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onFlow, onMessage
protected final AbstractConnectionContext connection
protected final AbstractProtonSessionContext protonSession
protected final org.apache.qpid.proton.engine.Receiver receiver
protected String address
protected final AMQPSessionCallback sessionSPI
public AbstractProtonReceiverContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, AbstractProtonSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver)
public void close(boolean remoteLinkClose) throws ActiveMQAMQPException
close
in interface ProtonDeliveryHandler
ActiveMQAMQPException
public void close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) throws ActiveMQAMQPException
close
in interface ProtonDeliveryHandler
ActiveMQAMQPException
public void flow(int credits, int threshold)
public void drain(int credits)
public int drained()
public boolean isDraining()
Copyright © 2016 The Apache Software Foundation. All rights reserved.