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

Class LinkedBlockingQueueSubscribableChannelFactory

java.lang.Object

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

All Implemented Interfaces:

ISubscribableChannelFactory

public class LinkedBlockingQueueSubscribableChannelFactory
extends Object
implements ISubscribableChannelFactory

Constructor Summary

Constructors

Constructor	Description
LinkedBlockingQueueSubscribableChannelFactory()

Method Summary

Modifier and Type	Method	Description
org.springframework.messaging.SubscribableChannel	createSubscribableChannel(String theChannelName, Class theMessageType, int theConcurrentConsumers)
int	getDeliveryChannelConcurrentConsumers()
int	getMatchingChannelConcurrentConsumers()

Methods inherited from class java.lang.Object

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

Constructor Detail

LinkedBlockingQueueSubscribableChannelFactory

public LinkedBlockingQueueSubscribableChannelFactory()

Method Detail

createSubscribableChannel

public org.springframework.messaging.SubscribableChannel createSubscribableChannel(String theChannelName,
                                                                                   Class theMessageType,
                                                                                   int theConcurrentConsumers)

Specified by:

createSubscribableChannel in interface ISubscribableChannelFactory

getDeliveryChannelConcurrentConsumers

public int getDeliveryChannelConcurrentConsumers()

Specified by:

getDeliveryChannelConcurrentConsumers in interface ISubscribableChannelFactory

getMatchingChannelConcurrentConsumers

public int getMatchingChannelConcurrentConsumers()

Specified by:

getMatchingChannelConcurrentConsumers in interface ISubscribableChannelFactory