Package ca.uhn.fhir.jpa.subscription.module

Class LinkedBlockingQueueSubscribableChannel

java.lang.Object

ca.uhn.fhir.jpa.subscription.module.LinkedBlockingQueueSubscribableChannel

All Implemented Interfaces:

org.springframework.messaging.MessageChannel, org.springframework.messaging.SubscribableChannel

public class LinkedBlockingQueueSubscribableChannel
extends Object
implements org.springframework.messaging.SubscribableChannel

Field Summary

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
LinkedBlockingQueueSubscribableChannel(BlockingQueue<Runnable> theQueue, String theThreadNamingPattern, int theConcurrentConsumers)

Method Summary

Modifier and Type	Method	Description
void	addInterceptorForUnitTest(org.springframework.messaging.support.ChannelInterceptor theInterceptor)
void	clearInterceptorsForUnitTest()
int	getQueueSizeForUnitTest()
boolean	send(org.springframework.messaging.Message<?> message, long timeout)
boolean	subscribe(org.springframework.messaging.MessageHandler handler)
boolean	unsubscribe(org.springframework.messaging.MessageHandler handler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.messaging.MessageChannel

send

Constructor Detail

LinkedBlockingQueueSubscribableChannel

public LinkedBlockingQueueSubscribableChannel(BlockingQueue<Runnable> theQueue,
                                              String theThreadNamingPattern,
                                              int theConcurrentConsumers)

Method Detail

subscribe

public boolean subscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

subscribe in interface org.springframework.messaging.SubscribableChannel

unsubscribe

public boolean unsubscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

unsubscribe in interface org.springframework.messaging.SubscribableChannel

send

public boolean send(org.springframework.messaging.Message<?> message,
                    long timeout)

Specified by:

send in interface org.springframework.messaging.MessageChannel

clearInterceptorsForUnitTest

public void clearInterceptorsForUnitTest()

addInterceptorForUnitTest

public void addInterceptorForUnitTest(org.springframework.messaging.support.ChannelInterceptor theInterceptor)

getQueueSizeForUnitTest

public int getQueueSizeForUnitTest()