Package ca.uhn.fhir.jpa.subscription.module.cache

Class SubscriptionRegistry

java.lang.Object

ca.uhn.fhir.jpa.subscription.module.cache.SubscriptionRegistry

@Component
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()
boolean	registerSubscriptionUnlessAlreadyRegistered(org.hl7.fhir.instance.model.api.IBaseResource theSubscription)
int	size()
void	unregisterAllSubscriptions()
void	unregisterSubscription(String theSubscriptionId)
boolean	unregisterSubscriptionIfRegistered(org.hl7.fhir.instance.model.api.IBaseResource theSubscription, String theStatusString)

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriptionRegistry

public SubscriptionRegistry()

Constructor

Method Detail

get

public ActiveSubscription get(String theIdPart)

getAll

public Collection<ActiveSubscription> getAll()

unregisterSubscription

public void unregisterSubscription(String theSubscriptionId)

unregisterAllSubscriptions

@PreDestroy
public void unregisterAllSubscriptions()

registerSubscriptionUnlessAlreadyRegistered

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

unregisterSubscriptionIfRegistered

public boolean unregisterSubscriptionIfRegistered(org.hl7.fhir.instance.model.api.IBaseResource theSubscription,
                                                  String theStatusString)

size

public int size()