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, Executor theExecutor, Supplier<Integer> theQueueSizeSupplier)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    clearInterceptorsForUnitTest()
     
    void
    destroy()
     
    String
    getName()
     
    int
    getQueueSizeForUnitTest()
     
    boolean
    hasSubscription(org.springframework.messaging.MessageHandler handler)
     
    static LinkedBlockingChannel
    newSynchronous(String theName)
    Creates a synchronous channel, mostly intended for testing
    boolean
    subscribe(org.springframework.messaging.MessageHandler theHandler)
     
    boolean
    unsubscribe(org.springframework.messaging.MessageHandler handler)
     

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

    addInterceptor, addInterceptor, getExecutor, sendInternal, setInterceptors

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

    getSubscribers

    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

  • Constructor Details

  • Method Details

    • getQueueSizeForUnitTest

      public int getQueueSizeForUnitTest()

    • clearInterceptorsForUnitTest

      public void clearInterceptorsForUnitTest()

    • getName

      public String getName()
      Specified by:
      getName in interface IChannelReceiver

    • hasSubscription

      public boolean hasSubscription(@Nonnull org.springframework.messaging.MessageHandler handler)
      Overrides:
      hasSubscription in class org.springframework.messaging.support.AbstractSubscribableChannel

    • subscribe

      public boolean subscribe(@Nonnull org.springframework.messaging.MessageHandler theHandler)
      Specified by:
      subscribe in interface org.springframework.messaging.SubscribableChannel
      Overrides:
      subscribe in class org.springframework.messaging.support.AbstractSubscribableChannel

    • unsubscribe

      public boolean unsubscribe(@Nonnull org.springframework.messaging.MessageHandler handler)
      Specified by:
      unsubscribe in interface org.springframework.messaging.SubscribableChannel
      Overrides:
      unsubscribe in class org.springframework.messaging.support.AbstractSubscribableChannel

    • destroy

      public void destroy()
      Specified by:
      destroy in interface org.springframework.beans.factory.DisposableBean

    • newSynchronous

      public static LinkedBlockingChannel newSynchronous(String theName)
      Creates a synchronous channel, mostly intended for testing