
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
-
-
Constructor Summary
Constructors Constructor Description LinkedBlockingChannel(String theName, ThreadPoolExecutor theExecutor, BlockingQueue<?> theQueue)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 interfaceIChannelReceiver
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceorg.springframework.beans.factory.DisposableBean
-
-