org.apache.ambari.server.agent.stomp

Class AmbariSubscriptionRegistry

java.lang.Object

org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

org.apache.ambari.server.agent.stomp.AmbariSubscriptionRegistry

All Implemented Interfaces:

org.springframework.messaging.simp.broker.SubscriptionRegistry

public class AmbariSubscriptionRegistry
extends org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

Implementation of SubscriptionRegistry that has configurable cache size, optimized working with cache and destinations matching.

Field Summary

Fields inherited from class org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

logger

Constructor Summary

Constructors

Constructor and Description
AmbariSubscriptionRegistry(int cacheLimit)

Method Summary

Modifier and Type	Method and Description
protected void	addSubscriptionInternal(String sessionId, String subsId, String destination, org.springframework.messaging.Message<?> message)
protected org.springframework.util.MultiValueMap<String,String>	findSubscriptionsInternal(String destination, org.springframework.messaging.Message<?> message)
int	getCacheLimit() Return the maximum number of entries for the resolved destination cache.
org.springframework.util.PathMatcher	getPathMatcher() Return the configured PathMatcher.
String	getSelectorHeaderName() Return the name for the selector header.
protected void	removeSubscriptionInternal(String sessionId, String subsId, org.springframework.messaging.Message<?> message)
void	setCacheLimit(int cacheLimit) Specify the maximum number of entries for the resolved destination cache.
void	setPathMatcher(org.springframework.util.PathMatcher pathMatcher) Specify the PathMatcher to use.
void	setSelectorHeaderName(String selectorHeaderName) Configure the name of a selector header that a subscription message can have in order to filter messages based on their headers.
String	toString()
void	unregisterAllSubscriptions(String sessionId)

Methods inherited from class org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

findSubscriptions, registerSubscription, unregisterSubscription

Methods inherited from class java.lang.Object

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

Constructor Detail

AmbariSubscriptionRegistry

public AmbariSubscriptionRegistry(int cacheLimit)

Method Detail

setPathMatcher

public void setPathMatcher(org.springframework.util.PathMatcher pathMatcher)

Specify the PathMatcher to use.

getPathMatcher

public org.springframework.util.PathMatcher getPathMatcher()

Return the configured PathMatcher.

setCacheLimit

public void setCacheLimit(int cacheLimit)

Specify the maximum number of entries for the resolved destination cache. Default is 1024.

getCacheLimit

public int getCacheLimit()

Return the maximum number of entries for the resolved destination cache.

setSelectorHeaderName

public void setSelectorHeaderName(String selectorHeaderName)

Configure the name of a selector header that a subscription message can have in order to filter messages based on their headers. The value of the header can use Spring EL expressions against message headers.

For example the following expression expects a header called "foo" to have the value "bar":

 headers.foo == 'bar'
 

By default this is set to "selector".

Since:

4.2

getSelectorHeaderName

public String getSelectorHeaderName()

Return the name for the selector header.

Since:

4.2

addSubscriptionInternal

protected void addSubscriptionInternal(String sessionId,
                                       String subsId,
                                       String destination,
                                       org.springframework.messaging.Message<?> message)

Specified by:

addSubscriptionInternal in class org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

removeSubscriptionInternal

protected void removeSubscriptionInternal(String sessionId,
                                          String subsId,
                                          org.springframework.messaging.Message<?> message)

Specified by:

removeSubscriptionInternal in class org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

unregisterAllSubscriptions

public void unregisterAllSubscriptions(String sessionId)

findSubscriptionsInternal

protected org.springframework.util.MultiValueMap<String,String> findSubscriptionsInternal(String destination,
                                                                                          org.springframework.messaging.Message<?> message)

Specified by:

findSubscriptionsInternal in class org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry

toString

public String toString()

Overrides:

toString in class Object