org.apache.activemq.artemis.core.protocol.proton.plug

Class ProtonSessionIntegrationCallback

java.lang.Object

org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback

All Implemented Interfaces:

SessionCallback, AMQPSessionCallback

public class ProtonSessionIntegrationCallback
extends Object
implements AMQPSessionCallback, SessionCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected IDGenerator	consumerIDGenerator

Constructor Summary

Constructors

Constructor and Description
ProtonSessionIntegrationCallback(ActiveMQProtonConnectionCallback protonSPI, ProtonProtocolManager manager, AMQPConnectionContext connection, Connection transportConnection, Executor executor)

Method Summary

Modifier and Type	Method and Description
void	ack(Object brokerConsumer, Object message)
void	afterDelivery() This can be used to complete certain operations outside of the lock, like acks or other operations.
boolean	bindingQuery(String address)
void	browserFinished(ServerConsumer consumer) Some protocols (Openwire) needs a special message with the browser is finished.
void	cancel(Object brokerConsumer, Object message, boolean updateCounts)
void	close()
void	closed()
void	closeSender(Object brokerConsumer)
void	commitCurrentTX()
void	createDurableQueue(String address, String queueName)
Object	createSender(ProtonPlugSender protonSender, String queue, String filter, boolean browserOnly)
void	createTemporaryQueue(String queueName)
void	createTemporaryQueue(String address, String queueName)
void	deleteQueue(String address)
void	disconnect(ServerConsumer consumer, String queueName)
org.apache.qpid.proton.message.ProtonJMessage	encodeMessage(Object message, int deliveryCount)
org.apache.qpid.proton.amqp.Binary	getCurrentTXID()
String	getPubSubPrefix()
boolean	hasCredits(ServerConsumer consumer) This one gives a chance for Proton to have its own flow control.
void	init(AMQPSessionContext protonSession, SASLResult saslResult)
boolean	isWritable(ReadyListener callback)
void	offerProducerCredit(String address, int credits, int threshold, org.apache.qpid.proton.engine.Receiver receiver)
void	onFlowConsumer(Object consumer, int credits, boolean drain)
boolean	queueQuery(String queueName)
void	resumeDelivery(Object consumer)
void	rollbackCurrentTX(boolean lastMessageDelivered)
int	sendLargeMessage(MessageReference ref, ServerMessage message, ServerConsumer consumer, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(ServerConsumer consumer, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(MessageReference ref, ServerMessage message, ServerConsumer consumer, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)
void	serverSend(org.apache.qpid.proton.engine.Receiver receiver, org.apache.qpid.proton.engine.Delivery delivery, String address, int messageFormat, io.netty.buffer.ByteBuf messageEncoded)
void	start()
void	startSender(Object brokerConsumer)
String	tempQueueName()
boolean	updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed) Use this to updates specifics on the message after a redelivery happened.

Methods inherited from class java.lang.Object

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

Field Detail

consumerIDGenerator

protected final IDGenerator consumerIDGenerator

Constructor Detail

ProtonSessionIntegrationCallback

public ProtonSessionIntegrationCallback(ActiveMQProtonConnectionCallback protonSPI,
                                        ProtonProtocolManager manager,
                                        AMQPConnectionContext connection,
                                        Connection transportConnection,
                                        Executor executor)

Method Detail

isWritable

public boolean isWritable(ReadyListener callback)

Specified by:

isWritable in interface SessionCallback

onFlowConsumer

public void onFlowConsumer(Object consumer,
                           int credits,
                           boolean drain)

Specified by:

onFlowConsumer in interface AMQPSessionCallback

browserFinished

public void browserFinished(ServerConsumer consumer)

Description copied from interface: SessionCallback

Some protocols (Openwire) needs a special message with the browser is finished.

Specified by:

browserFinished in interface SessionCallback

init

public void init(AMQPSessionContext protonSession,
                 SASLResult saslResult)
          throws Exception

Specified by:

init in interface AMQPSessionCallback

Throws:

Exception

afterDelivery

public void afterDelivery()
                   throws Exception

Description copied from interface: SessionCallback

This can be used to complete certain operations outside of the lock, like acks or other operations.

Specified by:

afterDelivery in interface SessionCallback

Throws:

Exception

start

public void start()

Specified by:

start in interface AMQPSessionCallback

createSender

public Object createSender(ProtonPlugSender protonSender,
                           String queue,
                           String filter,
                           boolean browserOnly)
                    throws Exception

Specified by:

createSender in interface AMQPSessionCallback

Throws:

Exception

startSender

public void startSender(Object brokerConsumer)
                 throws Exception

Specified by:

startSender in interface AMQPSessionCallback

Throws:

Exception

createTemporaryQueue

public void createTemporaryQueue(String queueName)
                          throws Exception

Specified by:

createTemporaryQueue in interface AMQPSessionCallback

Throws:

Exception

createTemporaryQueue

public void createTemporaryQueue(String address,
                                 String queueName)
                          throws Exception

Specified by:

createTemporaryQueue in interface AMQPSessionCallback

Throws:

Exception

createDurableQueue

public void createDurableQueue(String address,
                               String queueName)
                        throws Exception

Specified by:

createDurableQueue in interface AMQPSessionCallback

Throws:

Exception

queueQuery

public boolean queueQuery(String queueName)
                   throws Exception

Specified by:

queueQuery in interface AMQPSessionCallback

Throws:

Exception

bindingQuery

public boolean bindingQuery(String address)
                     throws Exception

Specified by:

bindingQuery in interface AMQPSessionCallback

Throws:

Exception

closeSender

public void closeSender(Object brokerConsumer)
                 throws Exception

Specified by:

closeSender in interface AMQPSessionCallback

Throws:

Exception

encodeMessage

public org.apache.qpid.proton.message.ProtonJMessage encodeMessage(Object message,
                                                                   int deliveryCount)
                                                            throws Exception

Specified by:

encodeMessage in interface AMQPSessionCallback

Throws:

Exception

getCurrentTXID

public org.apache.qpid.proton.amqp.Binary getCurrentTXID()

Specified by:

getCurrentTXID in interface AMQPSessionCallback

tempQueueName

public String tempQueueName()

Specified by:

tempQueueName in interface AMQPSessionCallback

commitCurrentTX

public void commitCurrentTX()
                     throws Exception

Specified by:

commitCurrentTX in interface AMQPSessionCallback

Throws:

Exception

rollbackCurrentTX

public void rollbackCurrentTX(boolean lastMessageDelivered)
                       throws Exception

Specified by:

rollbackCurrentTX in interface AMQPSessionCallback

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AMQPSessionCallback

Throws:

Exception

ack

public void ack(Object brokerConsumer,
                Object message)
         throws Exception

Specified by:

ack in interface AMQPSessionCallback

Throws:

Exception

cancel

public void cancel(Object brokerConsumer,
                   Object message,
                   boolean updateCounts)
            throws Exception

Specified by:

cancel in interface AMQPSessionCallback

updateCounts - this identified if the cancel was because of a failure or just cleaning up the client's cache. in some implementations you could call this failed

Throws:

Exception

resumeDelivery

public void resumeDelivery(Object consumer)

Specified by:

resumeDelivery in interface AMQPSessionCallback

serverSend

public void serverSend(org.apache.qpid.proton.engine.Receiver receiver,
                       org.apache.qpid.proton.engine.Delivery delivery,
                       String address,
                       int messageFormat,
                       io.netty.buffer.ByteBuf messageEncoded)
                throws Exception

Specified by:

serverSend in interface AMQPSessionCallback

messageEncoded - a Heap Buffer ByteBuffer (safe to convert into byte[])

Throws:

Exception

getPubSubPrefix

public String getPubSubPrefix()

Specified by:

getPubSubPrefix in interface AMQPSessionCallback

offerProducerCredit

public void offerProducerCredit(String address,
                                int credits,
                                int threshold,
                                org.apache.qpid.proton.engine.Receiver receiver)

Specified by:

offerProducerCredit in interface AMQPSessionCallback

deleteQueue

public void deleteQueue(String address)
                 throws Exception

Specified by:

deleteQueue in interface AMQPSessionCallback

Throws:

Exception

sendProducerCreditsMessage

public void sendProducerCreditsMessage(int credits,
                                       SimpleString address)

Specified by:

sendProducerCreditsMessage in interface SessionCallback

updateDeliveryCountAfterCancel

public boolean updateDeliveryCountAfterCancel(ServerConsumer consumer,
                                              MessageReference ref,
                                              boolean failed)

Description copied from interface: SessionCallback

Use this to updates specifics on the message after a redelivery happened. Return true if there was specific logic applied on the protocol, so the ServerConsumer won't make any adjustments.

Specified by:

updateDeliveryCountAfterCancel in interface SessionCallback

sendProducerCreditsFailMessage

public void sendProducerCreditsFailMessage(int credits,
                                           SimpleString address)

Specified by:

sendProducerCreditsFailMessage in interface SessionCallback

sendMessage

public int sendMessage(MessageReference ref,
                       ServerMessage message,
                       ServerConsumer consumer,
                       int deliveryCount)

Specified by:

sendMessage in interface SessionCallback

sendLargeMessage

public int sendLargeMessage(MessageReference ref,
                            ServerMessage message,
                            ServerConsumer consumer,
                            long bodySize,
                            int deliveryCount)

Specified by:

sendLargeMessage in interface SessionCallback

sendLargeMessageContinuation

public int sendLargeMessageContinuation(ServerConsumer consumer,
                                        byte[] body,
                                        boolean continues,
                                        boolean requiresResponse)

Specified by:

sendLargeMessageContinuation in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

disconnect

public void disconnect(ServerConsumer consumer,
                       String queueName)

Specified by:

disconnect in interface SessionCallback

hasCredits

public boolean hasCredits(ServerConsumer consumer)

Description copied from interface: SessionCallback

This one gives a chance for Proton to have its own flow control.

Specified by:

hasCredits in interface SessionCallback