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)
SubscriptionChannelWithHandlers	getDeliveryReceiverChannel(String theChannelName)
org.springframework.messaging.MessageChannel	getDeliverySenderChannel(String theChannelName)
void	logForUnitTest()
protected IChannelReceiver	newReceivingChannel(ReceivingChannelParameters theParameters)
protected IChannelProducer	newSendingChannel(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)

newReceivingChannel

protected IChannelReceiver newReceivingChannel(ReceivingChannelParameters theParameters)

newSendingChannel

protected IChannelProducer newSendingChannel(ProducingChannelParameters theParameters)

remove

public void remove(ActiveSubscription theActiveSubscription)

getDeliveryReceiverChannel

public SubscriptionChannelWithHandlers getDeliveryReceiverChannel(String theChannelName)

getDeliverySenderChannel

public org.springframework.messaging.MessageChannel getDeliverySenderChannel(String theChannelName)

size

public int size()

logForUnitTest

public void logForUnitTest()