public class ProtonClientReceiverContext extends AbstractProtonReceiverContext implements AMQPClientReceiverContext
address, connection, protonSession, receiver, sessionSPI
Constructor and Description |
---|
ProtonClientReceiverContext(AMQPSessionCallback sessionSPI,
AbstractConnectionContext connection,
AbstractProtonSessionContext protonSession,
org.apache.qpid.proton.engine.Receiver receiver) |
Modifier and Type | Method and Description |
---|---|
void |
flow(int credits) |
void |
onFlow(int credits,
boolean drain) |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
org.apache.qpid.proton.message.ProtonJMessage |
receiveMessage(int time,
TimeUnit unit) |
close, close, drain, drained, flow, isDraining
afterInit, initialise, isInitialized, waitWithTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
drain, drained, isDraining
public ProtonClientReceiverContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, AbstractProtonSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver)
public void onFlow(int credits, boolean drain)
onFlow
in interface ProtonDeliveryHandler
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws ActiveMQAMQPException
onMessage
in interface ProtonDeliveryHandler
ActiveMQAMQPException
public org.apache.qpid.proton.message.ProtonJMessage receiveMessage(int time, TimeUnit unit) throws Exception
receiveMessage
in interface AMQPClientReceiverContext
Exception
public void flow(int credits)
flow
in interface AMQPClientReceiverContext
Copyright © 2016 The Apache Software Foundation. All rights reserved.