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

Class LinkedBlockingChannelFactory

java.lang.Object

ca.uhn.fhir.jpa.subscription.channel.impl.LinkedBlockingChannelFactory

public class LinkedBlockingChannelFactory
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected RetryPolicyProvider	myRetryPolicyProvider

Constructor Summary

Constructors

Constructor	Description
LinkedBlockingChannelFactory(IChannelNamer theChannelNamer, RetryPolicyProvider theRetryPolicyProvider)

Method Summary

Modifier and Type	Method	Description
protected LinkedBlockingChannel	buildLinkedBlockingChannel(int theConcurrentConsumers, String theChannelName)
IChannelNamer	getChannelNamer()
ISpringMessagingChannelProducer	getOrCreateProducer(String theChannelName, ChannelProducerSettings theChannelSettings)
LinkedBlockingChannel	getOrCreateReceiver(String theChannelName, ChannelConsumerSettings theChannelSettings)
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

myRetryPolicyProvider

protected RetryPolicyProvider myRetryPolicyProvider

Constructor Details

LinkedBlockingChannelFactory

public LinkedBlockingChannelFactory(IChannelNamer theChannelNamer,
 RetryPolicyProvider theRetryPolicyProvider)

Method Details

getOrCreateReceiver

public LinkedBlockingChannel getOrCreateReceiver(String theChannelName,
 ChannelConsumerSettings theChannelSettings)

getOrCreateProducer

public ISpringMessagingChannelProducer getOrCreateProducer(String theChannelName,
 ChannelProducerSettings theChannelSettings)

getChannelNamer

public IChannelNamer getChannelNamer()

buildLinkedBlockingChannel

@Nonnull
protected LinkedBlockingChannel buildLinkedBlockingChannel(int theConcurrentConsumers,
 String theChannelName)

stop

@PreDestroy
public void stop()