Package ca.uhn.fhir.jpa.subscription.channel.subscription

Class SubscriptionChannelRegistry

java.lang.Object

ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelRegistry

public class SubscriptionChannelRegistry
extends Object

Constructor Summary

Constructors

Constructor	Description
SubscriptionChannelRegistry()

Method Summary

Modifier and Type	Method	Description
void	add(ActiveSubscription theActiveSubscription)
IChannelProducer<ResourceDeliveryMessage>	getDeliveryChannelProducer(String theChannelName)
SubscriptionResourceDeliveryMessageConsumer	getDeliveryConsumerWithListeners(String theChannelName)
void	logForUnitTest()
protected IChannelConsumer<ResourceDeliveryMessage>	newDeliveryConsumer(IMessageListener<ResourceDeliveryMessage> theListener, ReceivingChannelParameters theParameters)
protected IChannelProducer<ResourceDeliveryMessage>	newProducer(ProducingChannelParameters theParameters)
void	remove(ActiveSubscription theActiveSubscription)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionChannelRegistry

public SubscriptionChannelRegistry()

Method Details

add

public void add(ActiveSubscription theActiveSubscription)

newDeliveryConsumer

protected IChannelConsumer<ResourceDeliveryMessage> newDeliveryConsumer(IMessageListener<ResourceDeliveryMessage> theListener,
 ReceivingChannelParameters theParameters)

newProducer

protected IChannelProducer<ResourceDeliveryMessage> newProducer(ProducingChannelParameters theParameters)

remove

public void remove(ActiveSubscription theActiveSubscription)

getDeliveryConsumerWithListeners

public SubscriptionResourceDeliveryMessageConsumer getDeliveryConsumerWithListeners(String theChannelName)

getDeliveryChannelProducer

public IChannelProducer<ResourceDeliveryMessage> getDeliveryChannelProducer(String theChannelName)

size

public int size()

logForUnitTest

public void logForUnitTest()