public class ProtonServerSenderContext extends AbstractProtonContextSender implements ProtonPlugSender
closed, connection, creditsSemaphore, protonSession, sender, sessionSPI
Constructor and Description |
---|
ProtonServerSenderContext(AbstractConnectionContext connection,
org.apache.qpid.proton.engine.Sender sender,
AbstractProtonSessionContext protonSession,
AMQPSessionCallback server) |
Modifier and Type | Method and Description |
---|---|
void |
checkState() |
void |
close(boolean remoteLinkClose) |
void |
close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) |
int |
deliverMessage(Object message,
int deliveryCount)
handle an out going message from ActiveMQ Artemis, send via the Proton Sender
|
Object |
getBrokerConsumer() |
void |
initialise()
create the actual underlying ActiveMQ Artemis Server Consumer
|
void |
onFlow(int currentCredits,
boolean drain) |
void |
onMessage(org.apache.qpid.proton.engine.Delivery delivery) |
void |
start() |
getSender, performSend
afterInit, isInitialized, waitWithTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSender
public ProtonServerSenderContext(AbstractConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AbstractProtonSessionContext protonSession, AMQPSessionCallback server)
public Object getBrokerConsumer()
public void onFlow(int currentCredits, boolean drain)
onFlow
in interface ProtonDeliveryHandler
onFlow
in class AbstractProtonContextSender
public void start() throws ActiveMQAMQPException
start
in class AbstractProtonContextSender
ActiveMQAMQPException
public void initialise() throws Exception
initialise
in class ProtonInitializable
Exception
public void close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) throws ActiveMQAMQPException
close
in interface ProtonDeliveryHandler
close
in class AbstractProtonContextSender
ActiveMQAMQPException
public void close(boolean remoteLinkClose) throws ActiveMQAMQPException
close
in interface ProtonDeliveryHandler
close
in class AbstractProtonContextSender
ActiveMQAMQPException
public void onMessage(org.apache.qpid.proton.engine.Delivery delivery) throws ActiveMQAMQPException
onMessage
in interface ProtonDeliveryHandler
onMessage
in class AbstractProtonContextSender
ActiveMQAMQPException
public void checkState()
checkState
in class AbstractProtonContextSender
public int deliverMessage(Object message, int deliveryCount) throws Exception
deliverMessage
in interface ProtonPlugSender
Exception
Copyright © 2016 The Apache Software Foundation. All rights reserved.