org.apache.activemq.artemis.core.protocol.stomp

Class StompSession

java.lang.Object

org.apache.activemq.artemis.core.protocol.stomp.StompSession

All Implemented Interfaces:

SessionCallback

public class StompSession
extends Object
implements SessionCallback

Method Summary

Modifier and Type	Method and Description
void	acknowledge(String messageID, String subscriptionID)
void	addSubscription(long consumerID, String subscriptionID, String clientID, String durableSubscriptionName, String destination, String selector, String ack)
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.
void	closed()
void	disconnect(ServerConsumer consumerId, String queueName)
RemotingConnection	getConnection()
OperationContext	getContext()
ServerSession	getSession()
boolean	hasCredits(ServerConsumer consumerID) This one gives a chance for Proton to have its own flow control.
boolean	isNoLocal()
boolean	isWritable(ReadyListener callback)
void	sendInternal(ServerMessageImpl message, boolean direct)
void	sendInternalLarge(ServerMessageImpl message, boolean direct)
int	sendLargeMessage(MessageReference ref, ServerMessage msg, ServerConsumer consumer, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(ServerConsumer consumer, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(MessageReference ref, ServerMessage serverMessage, ServerConsumer consumer, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)
void	setNoLocal(boolean noLocal)
boolean	unsubscribe(String id, String durableSubscriptionName, String clientID)
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

Method Detail

isWritable

public boolean isWritable(ReadyListener callback)

Specified by:

isWritable in interface SessionCallback

getSession

public ServerSession getSession()

hasCredits

public boolean hasCredits(ServerConsumer consumerID)

Description copied from interface: SessionCallback

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

Specified by:

hasCredits in interface SessionCallback

sendProducerCreditsMessage

public void sendProducerCreditsMessage(int credits,
                                       SimpleString address)

Specified by:

sendProducerCreditsMessage in interface SessionCallback

sendProducerCreditsFailMessage

public void sendProducerCreditsFailMessage(int credits,
                                           SimpleString address)

Specified by:

sendProducerCreditsFailMessage in interface SessionCallback

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

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

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

sendMessage

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

Specified by:

sendMessage in interface SessionCallback

sendLargeMessageContinuation

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

Specified by:

sendLargeMessageContinuation in interface SessionCallback

sendLargeMessage

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

Specified by:

sendLargeMessage in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

disconnect

public void disconnect(ServerConsumer consumerId,
                       String queueName)

Specified by:

disconnect in interface SessionCallback

acknowledge

public void acknowledge(String messageID,
                        String subscriptionID)
                 throws Exception

Throws:

Exception

addSubscription

public void addSubscription(long consumerID,
                            String subscriptionID,
                            String clientID,
                            String durableSubscriptionName,
                            String destination,
                            String selector,
                            String ack)
                     throws Exception

Throws:

Exception

unsubscribe

public boolean unsubscribe(String id,
                           String durableSubscriptionName,
                           String clientID)
                    throws Exception

Throws:

Exception

getConnection

public RemotingConnection getConnection()

getContext

public OperationContext getContext()

isNoLocal

public boolean isNoLocal()

setNoLocal

public void setNoLocal(boolean noLocal)

sendInternal

public void sendInternal(ServerMessageImpl message,
                         boolean direct)
                  throws Exception

Throws:

Exception

sendInternalLarge

public void sendInternalLarge(ServerMessageImpl message,
                              boolean direct)
                       throws Exception

Throws:

Exception