public class ProtonServerReceiverContext extends AbstractProtonReceiverContext
address, connection, protonSession, receiver, sessionSPI
Constructor and Description |
---|
ProtonServerReceiverContext(AMQPSessionCallback sessionSPI,
AbstractConnectionContext connection,
AbstractProtonSessionContext protonSession,
org.apache.qpid.proton.engine.Receiver receiver) |
Modifier and Type | Method and Description |
---|---|
void |
initialise() |
void |
onFlow(int credits,
boolean drain) |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
close, close, drain, drained, flow, isDraining
afterInit, isInitialized, waitWithTimeout
public ProtonServerReceiverContext(AMQPSessionCallback sessionSPI, AbstractConnectionContext connection, AbstractProtonSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver)
public void onFlow(int credits, boolean drain)
public void initialise() throws Exception
initialise
in class ProtonInitializable
Exception
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws ActiveMQAMQPException
ActiveMQAMQPException
Copyright © 2016 The Apache Software Foundation. All rights reserved.