Package ca.uhn.fhir.jpa.subscription.match.registry

Class SubscriptionRegistry

java.lang.Object

ca.uhn.fhir.jpa.subscription.match.registry.SubscriptionRegistry

public class SubscriptionRegistry
extends Object

Cache of active subscriptions. When a new subscription is added to the cache, a new Spring Channel is created and a new MessageHandler for that subscription is subscribed to that channel. These subscriptions, channels, and handlers are all caches in this registry so they can be removed it the subscription is deleted.

Constructor Summary

Constructors

Constructor	Description
SubscriptionRegistry()	Constructor

Method Summary

Modifier and Type	Method	Description
ActiveSubscription	get(String theIdPart)
Collection<ActiveSubscription>	getAll()
List<ActiveSubscription>	getAllNonTopicSubscriptions()
List<ActiveSubscription>	getTopicSubscriptionsByTopic(String theTopic)
boolean	registerSubscriptionUnlessAlreadyRegistered(org.hl7.fhir.instance.model.api.IBaseResource theSubscription)
int	size()
void	unregisterAllSubscriptions()
void	unregisterSubscriptionIfRegistered(String theSubscriptionId)

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionRegistry

public SubscriptionRegistry()

Constructor

Method Details

get

public ActiveSubscription get(String theIdPart)

getAll

public Collection<ActiveSubscription> getAll()

getTopicSubscriptionsByTopic

public List<ActiveSubscription> getTopicSubscriptionsByTopic(String theTopic)

unregisterSubscriptionIfRegistered

public void unregisterSubscriptionIfRegistered(String theSubscriptionId)

unregisterAllSubscriptions

@PreDestroy
public void unregisterAllSubscriptions()

registerSubscriptionUnlessAlreadyRegistered

public boolean registerSubscriptionUnlessAlreadyRegistered(org.hl7.fhir.instance.model.api.IBaseResource theSubscription)

size

public int size()

getAllNonTopicSubscriptions

public List<ActiveSubscription> getAllNonTopicSubscriptions()