AbstractSubscriptionRegistry

Abstract base class for implementations of {@link SubscriptionRegistry} that looks up information in messages but delegates to abstract methods for the actual storage and retrieval.

@author Rossen Stoyanchev @since 4.0

abstract

class AbstractSubscriptionRegistry : SubscriptionRegistry {

void registerSubscription(MessageBase message);

void unregisterSubscription(MessageBase message);

MultiValueMap!(string, string) findSubscriptions(MessageBase message);

void addSubscriptionInternal(string sessionId, string subscriptionId, string destination, MessageBase message);

void removeSubscriptionInternal(string sessionId, string subscriptionId, MessageBase message);

MultiValueMap!(string, string) findSubscriptionsInternal(string destination, MessageBase message);

}

Members

Functions

addSubscriptionInternal void addSubscriptionInternal(string sessionId, string subscriptionId, string destination, MessageBase message): Undocumented in source.
findSubscriptions MultiValueMap!(string, string) findSubscriptions(MessageBase message): Undocumented in source. Be warned that the author may not have intended to support it.
findSubscriptionsInternal MultiValueMap!(string, string) findSubscriptionsInternal(string destination, MessageBase message): Undocumented in source.
registerSubscription void registerSubscription(MessageBase message): Undocumented in source. Be warned that the author may not have intended to support it.
removeSubscriptionInternal void removeSubscriptionInternal(string sessionId, string subscriptionId, MessageBase message): Undocumented in source.
unregisterSubscription void unregisterSubscription(MessageBase message): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From SubscriptionRegistry

registerSubscription void registerSubscription(MessageBase subscribeMessage): Register a subscription represented by the given message. @param subscribeMessage the subscription request
unregisterSubscription void unregisterSubscription(MessageBase unsubscribeMessage): Unregister a subscription. @param unsubscribeMessage the request to unsubscribe
unregisterAllSubscriptions void unregisterAllSubscriptions(string sessionId): Remove all subscriptions associated with the given sessionId.
findSubscriptions MultiValueMap!(string, string) findSubscriptions(MessageBase message): Find all subscriptions that should receive the given message. The map returned is safe to iterate and will never be modified. @param message the message @return a {@code MultiValueMap} with sessionId-subscriptionId pairs (possibly empty)

AbstractSubscriptionRegistry

Members

Functions

Inherited Members

From SubscriptionRegistry

Meta

Source