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()
     
    static LinkedBlockingChannel
    newSynchronous(String theName)
    Creates a synchronous channel, mostly intended for testing

    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