
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
ConstructorsConstructorDescriptionLinkedBlockingChannel
(String theName, ThreadPoolExecutor theExecutor, BlockingQueue<?> theQueue) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
destroy()
getName()
int
static LinkedBlockingChannel
newSynchronous
(String theName) Creates a synchronous channel, mostly intended for testingMethods 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 Details
-
LinkedBlockingChannel
public LinkedBlockingChannel(String theName, ThreadPoolExecutor theExecutor, BlockingQueue<?> theQueue)
-
-
Method Details
-
getQueueSizeForUnitTest
-
clearInterceptorsForUnitTest
-
getName
- Specified by:
getName
in interfaceIChannelReceiver
-
destroy
- Specified by:
destroy
in interfaceorg.springframework.beans.factory.DisposableBean
-
newSynchronous
Creates a synchronous channel, mostly intended for testing
-