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:
ISpringMessagingChannelProducer, ISpringMessagingChannelReceiver, 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 ISpringMessagingChannelProducer, ISpringMessagingChannelReceiver

  • 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 theChannelName, Executor theExecutor, Supplier<Integer> theQueueSizeSupplier, RetryPolicyProvider theRetryPolicyProvider)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    clearInterceptorsForUnitTest()
     
    void
    destroy()
     
    String
    getChannelName()
     
    int
    getQueueSizeForUnitTest()
     
    boolean
    hasSubscription(org.springframework.messaging.MessageHandler handler)
     
    static LinkedBlockingChannel
    newSynchronous(String theName, RetryPolicyProvider theRetryPolicyProvider)
    Creates a synchronous channel 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 ca.uhn.fhir.broker.jms.ISpringMessagingChannelReceiver

    pause, resume, start

    Methods inherited from interface org.springframework.messaging.MessageChannel

    send, send

  • Constructor Details

  • Method Details

    • getQueueSizeForUnitTest

      public int getQueueSizeForUnitTest()

    • clearInterceptorsForUnitTest

      public void clearInterceptorsForUnitTest()

    • getChannelName

      public String getChannelName()
      Specified by:
      getChannelName in interface ISpringMessagingChannelReceiver
      Returns:
      the name of the Queue this Channel Receiver consumes from

    • 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, RetryPolicyProvider theRetryPolicyProvider)
      Creates a synchronous channel for testing