org.apache.activemq.artemis.spi.core.protocol

Interface SessionCallback

All Known Implementing Classes:

CoreSessionCallback

public interface SessionCallback

Method Summary

Modifier and Type	Method and Description
void	afterDelivery() This can be used to complete certain operations outside of the lock, like acks or other operations.
void	browserFinished(ServerConsumer consumer) Some protocols (Openwire) needs a special message with the browser is finished.
default void	close(boolean failed)
void	closed()
void	disconnect(ServerConsumer consumerId, String queueName)
boolean	hasCredits(ServerConsumer consumerID) This one gives a chance for Proton to have its own flow control.
boolean	isWritable(ReadyListener callback)
int	sendLargeMessage(MessageReference reference, ServerMessage message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(MessageReference ref, ServerMessage message, ServerConsumer consumerID, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)
boolean	updateDeliveryCountAfterCancel(ServerConsumer consumer, MessageReference ref, boolean failed) Use this to updates specifics on the message after a redelivery happened.

Method Detail

hasCredits

boolean hasCredits(ServerConsumer consumerID)

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

afterDelivery

void afterDelivery()
            throws Exception

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

Throws:

Exception

updateDeliveryCountAfterCancel

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

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.

Parameters:

consumer -

ref -

failed -

sendProducerCreditsMessage

void sendProducerCreditsMessage(int credits,
                                SimpleString address)

sendProducerCreditsFailMessage

void sendProducerCreditsFailMessage(int credits,
                                    SimpleString address)

sendMessage

int sendMessage(MessageReference ref,
                ServerMessage message,
                ServerConsumer consumerID,
                int deliveryCount)

sendLargeMessage

int sendLargeMessage(MessageReference reference,
                     ServerMessage message,
                     ServerConsumer consumerID,
                     long bodySize,
                     int deliveryCount)

sendLargeMessageContinuation

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

closed

void closed()

disconnect

void disconnect(ServerConsumer consumerId,
                String queueName)

isWritable

boolean isWritable(ReadyListener callback)

browserFinished

void browserFinished(ServerConsumer consumer)

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

close

default void close(boolean failed)