public abstract class AbstractProtonContextSender extends ProtonInitializable implements ProtonDeliveryHandler
Modifier and Type | Field and Description |
---|---|
protected boolean |
closed |
protected AbstractConnectionContext |
connection |
protected CreditsSemaphore |
creditsSemaphore |
protected AbstractProtonSessionContext |
protonSession |
protected org.apache.qpid.proton.engine.Sender |
sender |
protected AMQPSessionCallback |
sessionSPI |
Constructor and Description |
---|
AbstractProtonContextSender(AbstractConnectionContext connection,
org.apache.qpid.proton.engine.Sender sender,
AbstractProtonSessionContext protonSession,
AMQPSessionCallback server) |
Modifier and Type | Method and Description |
---|---|
void |
checkState() |
void |
close(boolean linkRemoteClose) |
void |
close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
org.apache.qpid.proton.engine.Sender |
getSender() |
void |
onFlow(int credits,
boolean drain) |
abstract void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
protected int |
performSend(org.apache.qpid.proton.message.ProtonJMessage serverMessage,
Object context) |
void |
start() |
afterInit, initialise, isInitialized, waitWithTimeout
protected final AbstractProtonSessionContext protonSession
protected final org.apache.qpid.proton.engine.Sender sender
protected final AbstractConnectionContext connection
protected boolean closed
protected final AMQPSessionCallback sessionSPI
protected CreditsSemaphore creditsSemaphore
public AbstractProtonContextSender(AbstractConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AbstractProtonSessionContext protonSession, AMQPSessionCallback server)
public void onFlow(int credits, boolean drain)
onFlow
in interface ProtonDeliveryHandler
public void start() throws ActiveMQAMQPException
ActiveMQAMQPException
public void close(boolean linkRemoteClose) 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 abstract void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws ActiveMQAMQPException
onMessage
in interface ProtonDeliveryHandler
ActiveMQAMQPException
public void checkState()
public org.apache.qpid.proton.engine.Sender getSender()
protected int performSend(org.apache.qpid.proton.message.ProtonJMessage serverMessage, Object context)
Copyright © 2016 The Apache Software Foundation. All rights reserved.