org.hornetq.core.protocol.stomp

Class StompSession

java.lang.Object

org.hornetq.core.protocol.stomp.StompSession

All Implemented Interfaces:

SessionCallback

public class StompSession
extends Object
implements SessionCallback

A StompSession

Author:

Jeff Mesnil

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(String messageID, String subscriptionID)
void	addReadyListener(ReadyListener listener)
void	addSubscription(long consumerID, String subscriptionID, String clientID, String durableSubscriptionName, String destination, String selector, String ack)
void	closed()
RemotingConnection	getConnection()
OperationContext	getContext()
ServerSession	getSession()
boolean	isNoLocal()
void	removeReadyListener(ReadyListener listener)
void	sendInternal(ServerMessageImpl message, boolean direct)
void	sendInternalLarge(ServerMessageImpl message, boolean direct)
int	sendLargeMessage(ServerMessage msg, long consumerID, long bodySize, int deliveryCount)
int	sendLargeMessageContinuation(long consumerID, byte[] body, boolean continues, boolean requiresResponse)
int	sendMessage(ServerMessage serverMessage, long consumerID, int deliveryCount)
void	sendProducerCreditsFailMessage(int credits, SimpleString address)
void	sendProducerCreditsMessage(int credits, SimpleString address)
void	setNoLocal(boolean noLocal)
boolean	unsubscribe(String id, String durableSubscriptionName)

Methods inherited from class java.lang.Object

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

Method Detail

getSession

public ServerSession getSession()

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

sendMessage

public int sendMessage(ServerMessage serverMessage,
              long consumerID,
              int deliveryCount)

Specified by:

sendMessage in interface SessionCallback

sendLargeMessageContinuation

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

Specified by:

sendLargeMessageContinuation in interface SessionCallback

sendLargeMessage

public int sendLargeMessage(ServerMessage msg,
                   long consumerID,
                   long bodySize,
                   int deliveryCount)

Specified by:

sendLargeMessage in interface SessionCallback

closed

public void closed()

Specified by:

closed in interface SessionCallback

addReadyListener

public void addReadyListener(ReadyListener listener)

Specified by:

addReadyListener in interface SessionCallback

removeReadyListener

public void removeReadyListener(ReadyListener listener)

Specified by:

removeReadyListener 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)
                    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