org.kaazing.gateway.server.messaging

Interface MessagingSession

All Superinterfaces:

AttributeStore

public interface MessagingSession
extends AttributeStore

Represents an active link between a client and the messaging provider.

TODO: Transactions are not yet supported. TODO: May want to fire a messageSent event on the session for send acknowledgement.

Method Summary

Modifier and Type	Method and Description
void	acknowledgeMessage(MessagingMessage message)
void	acknowledgeMessage(String messageId)
void	acquireSubscription(String destination, Map<String,Object> attributes, MessagingHints hints, MessagingSubscriptionListener listener) Acquire a subscription for this session to the specified destination.
void	acquireSubscription(String destination, MessagingHints hints, MessagingSubscriptionListener listener)
String	getId() Get the globally unique session identifier.
void	reacquireSubscription(String subscriptionId, MessagingHints hints, MessagingSubscriptionListener listener)
void	releaseSubscription(MessagingSubscription subscription)
void	releaseSubscription(MessagingSubscription subscription, boolean reacquireable)
void	releaseSubscription(String subscriptionId)
void	releaseSubscription(String subscriptionId, boolean reacquireable)
void	send(String destination, Map<String,Object> attributes, Object payload)
void	send(String destination, Object payload)

Methods inherited from interface org.kaazing.gateway.service.messaging.AttributeStore

attributes, getAttribute, removeAttribute, setAttribute

Method Detail

getId

String getId()

Get the globally unique session identifier.

Returns:

unique session id

acquireSubscription

void acquireSubscription(String destination,
                         Map<String,Object> attributes,
                         MessagingHints hints,
                         MessagingSubscriptionListener listener)

Acquire a subscription for this session to the specified destination.

Notes on how some specific JMS features would be implemented:

selector - no selector, any filtering is done by protocol handlers or clients of messagingprovider ack_mode - no ack mode, all messages must be acknoledged by the client no_local - resolved by session.getId() and msg.getSender() compare is_durable - placed on the release for now. this will require us to pay for replication for all subscriptions. This could be changed.

Parameters:

destination -

attributes -

listener -

acquireSubscription

void acquireSubscription(String destination,
                         MessagingHints hints,
                         MessagingSubscriptionListener listener)

Parameters:

destination -

listener -

reacquireSubscription

void reacquireSubscription(String subscriptionId,
                           MessagingHints hints,
                           MessagingSubscriptionListener listener)

Parameters:

subscriptionId -

listener -

releaseSubscription

void releaseSubscription(String subscriptionId,
                         boolean reacquireable)

Parameters:

subscriptionId -

reacquireable -

releaseSubscription

void releaseSubscription(String subscriptionId)

Parameters:

subscriptionId -

releaseSubscription

void releaseSubscription(MessagingSubscription subscription,
                         boolean reacquireable)

Parameters:

subscription -

reacquireable -

releaseSubscription

void releaseSubscription(MessagingSubscription subscription)

Parameters:

subscription -

send

void send(String destination,
          Map<String,Object> attributes,
          Object payload)

Parameters:

destiantion -

attributes -

payload -

send

void send(String destination,
          Object payload)

Parameters:

destiantion -

payload -

acknowledgeMessage

void acknowledgeMessage(String messageId)

Parameters:

messageId -

acknowledgeMessage

void acknowledgeMessage(MessagingMessage message)

Parameters:

message -