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

Class LinkedBlockingChannel

java.lang.Object

org.springframework.messaging.support.AbstractMessageChannel

org.springframework.messaging.support.AbstractSubscribableChannel

org.springframework.messaging.support.ExecutorSubscribableChannel

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

All Implemented Interfaces:

IChannelProducer, IChannelReceiver, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.messaging.MessageChannel, org.springframework.messaging.SubscribableChannel, org.springframework.messaging.support.InterceptableChannel

public class LinkedBlockingChannel
extends org.springframework.messaging.support.ExecutorSubscribableChannel
implements IChannelProducer, IChannelReceiver

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.messaging.support.AbstractMessageChannel

org.springframework.messaging.support.AbstractMessageChannel.ChannelInterceptorChain

Field Summary

Fields inherited from class org.springframework.messaging.support.AbstractMessageChannel

logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
LinkedBlockingChannel(String theName, ThreadPoolExecutor theExecutor, BlockingQueue<?> theQueue)

Method Summary

Modifier and Type	Method	Description
void	clearInterceptorsForUnitTest()
void	destroy()
String	getName()
int	getQueueSizeForUnitTest()

Methods inherited from class org.springframework.messaging.support.ExecutorSubscribableChannel

addInterceptor, addInterceptor, getExecutor, sendInternal, setInterceptors

Methods inherited from class org.springframework.messaging.support.AbstractSubscribableChannel

getSubscribers, hasSubscription, subscribe, unsubscribe

Methods inherited from class org.springframework.messaging.support.AbstractMessageChannel

getBeanName, getInterceptors, getLogger, removeInterceptor, removeInterceptor, send, send, setBeanName, setLogger, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.messaging.support.InterceptableChannel

addInterceptor, addInterceptor, getInterceptors, removeInterceptor, removeInterceptor, setInterceptors

Methods inherited from interface org.springframework.messaging.MessageChannel

send, send

Methods inherited from interface org.springframework.messaging.SubscribableChannel

subscribe, unsubscribe

Constructor Detail

LinkedBlockingChannel

public LinkedBlockingChannel(String theName,
                             ThreadPoolExecutor theExecutor,
                             BlockingQueue<?> theQueue)

Method Detail

getQueueSizeForUnitTest

public int getQueueSizeForUnitTest()

clearInterceptorsForUnitTest

public void clearInterceptorsForUnitTest()

getName

public String getName()

Specified by:

getName in interface IChannelReceiver

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean