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	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(ServerMessage message, ServerConsumer consumerID, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(ServerConsumer consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(ServerMessage message, ServerConsumer consumerID, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)

Method Detail

hasCredits

boolean hasCredits(ServerConsumer consumerID)

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

sendProducerCreditsMessage

void sendProducerCreditsMessage(int credits,
                                SimpleString address)

sendProducerCreditsFailMessage

void sendProducerCreditsFailMessage(int credits,
                                    SimpleString address)

sendMessage

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

sendLargeMessage

int sendLargeMessage(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)