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

Class SubscriptionChannelFactory

java.lang.Object

ca.uhn.fhir.jpa.subscription.channel.subscription.SubscriptionChannelFactory

public class SubscriptionChannelFactory
extends Object

Constructor Summary

Constructors

Constructor	Description
SubscriptionChannelFactory(IBrokerClient theBrokerClient)	Constructor

Method Summary

Modifier and Type	Method	Description
IBrokerClient	getBrokerClient()
int	getDeliveryChannelConcurrentConsumers()
int	getMatchingChannelConcurrentConsumers()
protected ChannelConsumerSettings	newConsumerConfigForDeliveryChannel(ChannelConsumerSettings theOptions)
protected ChannelConsumerSettings	newConsumerConfigForMatchingChannel(ChannelConsumerSettings theOptions)
IChannelConsumer<ResourceDeliveryMessage>	newDeliveryConsumer(String theChannelName, IMessageListener<ResourceDeliveryMessage> theListener, ChannelConsumerSettings theChannelSettings)
IChannelProducer<ResourceDeliveryMessage>	newDeliveryProducer(String theChannelName, ChannelProducerSettings theChannelSettings)
IChannelConsumer<ResourceModifiedMessage>	newMatchingConsumer(String theChannelName, IMessageListener<ResourceModifiedMessage> theListener, ChannelConsumerSettings theChannelSettings)
IChannelProducer<ResourceModifiedMessage>	newMatchingProducer(String theChannelName, ChannelProducerSettings theChannelSettings)
protected ChannelProducerSettings	newProducerConfigForDeliveryChannel(ChannelProducerSettings theOptions)
protected ChannelProducerSettings	newProducerConfigForMatchingChannel(ChannelProducerSettings theOptions)

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionChannelFactory

public SubscriptionChannelFactory(IBrokerClient theBrokerClient)

Constructor

Method Details

newDeliveryProducer

public IChannelProducer<ResourceDeliveryMessage> newDeliveryProducer(String theChannelName,
 ChannelProducerSettings theChannelSettings)

newDeliveryConsumer

public IChannelConsumer<ResourceDeliveryMessage> newDeliveryConsumer(String theChannelName,
 IMessageListener<ResourceDeliveryMessage> theListener,
 ChannelConsumerSettings theChannelSettings)

newMatchingProducer

public IChannelProducer<ResourceModifiedMessage> newMatchingProducer(String theChannelName,
 ChannelProducerSettings theChannelSettings)

newMatchingConsumer

public IChannelConsumer<ResourceModifiedMessage> newMatchingConsumer(String theChannelName,
 IMessageListener<ResourceModifiedMessage> theListener,
 ChannelConsumerSettings theChannelSettings)

newProducerConfigForDeliveryChannel

protected ChannelProducerSettings newProducerConfigForDeliveryChannel(ChannelProducerSettings theOptions)

newConsumerConfigForDeliveryChannel

protected ChannelConsumerSettings newConsumerConfigForDeliveryChannel(ChannelConsumerSettings theOptions)

newProducerConfigForMatchingChannel

protected ChannelProducerSettings newProducerConfigForMatchingChannel(ChannelProducerSettings theOptions)

newConsumerConfigForMatchingChannel

protected ChannelConsumerSettings newConsumerConfigForMatchingChannel(ChannelConsumerSettings theOptions)

getDeliveryChannelConcurrentConsumers

public int getDeliveryChannelConcurrentConsumers()

getMatchingChannelConcurrentConsumers

public int getMatchingChannelConcurrentConsumers()

getBrokerClient

public IBrokerClient getBrokerClient()