Class ProtonServerSenderContext

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.proton.ProtonInitializable

org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext

All Implemented Interfaces:

ProtonDeliveryHandler

Direct Known Subclasses:

ProtonClientSenderContext

public class ProtonServerSenderContext
extends ProtonInitializable
implements ProtonDeliveryHandler

This is the Equivalent for the ServerConsumer

Field Summary

Fields

Modifier and Type	Field	Description
protected Runnable	afterDelivery
protected final AMQPConnectionContext	connection
protected static final byte[]	EMPTY_DELIVERY_TAG
protected MessageWriter	messageWriter
protected final AMQPSessionContext	protonSession
protected final org.apache.qpid.proton.engine.Sender	sender
protected final AMQPSessionCallback	sessionSPI

Fields inherited from class ProtonInitializable

initialized

Constructor Summary

Constructors

Constructor	Description
ProtonServerSenderContext(AMQPConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AMQPSessionContext protonSession, AMQPSessionCallback server)
ProtonServerSenderContext(AMQPConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AMQPSessionContext protonSession, AMQPSessionCallback server, SenderController senderController)

Method Summary

Modifier and Type	Method	Description
void	checkState()
void	close(boolean remoteLinkClose)
void	close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
int	deliverMessage(org.apache.activemq.artemis.core.server.MessageReference messageReference, org.apache.activemq.artemis.core.server.ServerConsumer consumer)	handle an out going message from ActiveMQ Artemis, send via the Proton Sender
protected void	doAck(Message message)
org.apache.activemq.artemis.core.server.ServerConsumer	getBrokerConsumer()
protected String	getClientId()
org.apache.qpid.proton.engine.Sender	getSender()
AMQPSessionContext	getSessionContext()
boolean	hasCredits()
void	initialize()	Create the actual underlying ActiveMQ Artemis Server Consumer
void	onFlow(int currentCredits, boolean drain)
void	onMessage(org.apache.qpid.proton.engine.Delivery delivery)
ProtonServerSenderContext	setBeforeDelivery(Consumer<? super org.apache.activemq.artemis.core.server.MessageReference> beforeDelivery)
void	settle(org.apache.qpid.proton.engine.Delivery delivery)
void	start()

Methods inherited from class ProtonInitializable

isInitialized

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

EMPTY_DELIVERY_TAG

protected static final byte[] EMPTY_DELIVERY_TAG

protonSession

protected final AMQPSessionContext protonSession

sender

protected final org.apache.qpid.proton.engine.Sender sender

connection

protected final AMQPConnectionContext connection

sessionSPI

protected final AMQPSessionCallback sessionSPI

afterDelivery

protected volatile Runnable afterDelivery

messageWriter

protected volatile MessageWriter messageWriter

Constructor Details

ProtonServerSenderContext

public ProtonServerSenderContext(AMQPConnectionContext connection,
 org.apache.qpid.proton.engine.Sender sender,
 AMQPSessionContext protonSession,
 AMQPSessionCallback server)

ProtonServerSenderContext

public ProtonServerSenderContext(AMQPConnectionContext connection,
 org.apache.qpid.proton.engine.Sender sender,
 AMQPSessionContext protonSession,
 AMQPSessionCallback server,
 SenderController senderController)

Method Details

setBeforeDelivery

public ProtonServerSenderContext setBeforeDelivery(Consumer<? super org.apache.activemq.artemis.core.server.MessageReference> beforeDelivery)

getBrokerConsumer

public org.apache.activemq.artemis.core.server.ServerConsumer getBrokerConsumer()

getClientId

protected String getClientId()

getSessionContext

public AMQPSessionContext getSessionContext()

getSender

public org.apache.qpid.proton.engine.Sender getSender()

onFlow

public void onFlow(int currentCredits,
 boolean drain)

Specified by:

onFlow in interface ProtonDeliveryHandler

hasCredits

public boolean hasCredits()

start

public void start()
           throws ActiveMQAMQPException

Throws:

ActiveMQAMQPException

initialize

public void initialize()
                throws Exception

Create the actual underlying ActiveMQ Artemis Server Consumer

Specified by:

initialize in class ProtonInitializable

Throws:

Exception

close

public void close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
           throws ActiveMQAMQPException

Specified by:

close in interface ProtonDeliveryHandler

Throws:

ActiveMQAMQPException

close

public void close(boolean remoteLinkClose)
           throws ActiveMQAMQPException

Specified by:

close in interface ProtonDeliveryHandler

Throws:

ActiveMQAMQPException

onMessage

public void onMessage(org.apache.qpid.proton.engine.Delivery delivery)
               throws ActiveMQAMQPException

Specified by:

onMessage in interface ProtonDeliveryHandler

Throws:

ActiveMQAMQPException

doAck

protected void doAck(Message message)
              throws ActiveMQAMQPIllegalStateException

Throws:

ActiveMQAMQPIllegalStateException

settle

public void settle(org.apache.qpid.proton.engine.Delivery delivery)

checkState

public void checkState()

deliverMessage

public int deliverMessage(org.apache.activemq.artemis.core.server.MessageReference messageReference,
 org.apache.activemq.artemis.core.server.ServerConsumer consumer)
                   throws Exception

handle an out going message from ActiveMQ Artemis, send via the Proton Sender

Throws:

Exception