Package ca.uhn.fhir.jpa.subscription.channel.impl

Class LinkedBlockingChannelFactory

java.lang.Object

ca.uhn.fhir.jpa.subscription.channel.impl.LinkedBlockingChannelFactory

All Implemented Interfaces:

IChannelFactory

public class LinkedBlockingChannelFactory
extends Object
implements IChannelFactory

Constructor Summary

Constructors

Constructor	Description
LinkedBlockingChannelFactory(IChannelNamer theChannelNamer)

Method Summary

Modifier and Type	Method	Description
IChannelNamer	getChannelNamer()
IChannelProducer	getOrCreateProducer(String theChannelName, Class<?> theMessageType, ChannelProducerSettings theChannelSettings)	Create a channel that is used to send messages to the queue.
IChannelReceiver	getOrCreateReceiver(String theChannelName, Class<?> theMessageType, ChannelConsumerSettings theChannelSettings)	Create a channel that is used to receive messages from the queue.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

LinkedBlockingChannelFactory

public LinkedBlockingChannelFactory(IChannelNamer theChannelNamer)

Method Details

getOrCreateReceiver

public IChannelReceiver getOrCreateReceiver(String theChannelName,
 Class<?> theMessageType,
 ChannelConsumerSettings theChannelSettings)

Description copied from interface: IChannelFactory

Create a channel that is used to receive messages from the queue.

Implementations can choose to return the same object for multiple invocations of this method (and IChannelFactory.getOrCreateReceiver(String, Class, ChannelConsumerSettings) when invoked with the same theChannelName if they need to, or they can create a new instance.

Specified by:

getOrCreateReceiver in interface IChannelFactory

Parameters:

theChannelName - The actual underlying queue name

theMessageType - The object type that will be placed on this queue. Objects will be Jackson-annotated structures.

theChannelSettings - Contains the configuration for subscribers.

getOrCreateProducer

public IChannelProducer getOrCreateProducer(String theChannelName,
 Class<?> theMessageType,
 ChannelProducerSettings theChannelSettings)

Description copied from interface: IChannelFactory

Create a channel that is used to send messages to the queue.

Implementations can choose to return the same object for multiple invocations of this method (and IChannelFactory.getOrCreateReceiver(String, Class, ChannelConsumerSettings) when invoked with the same theChannelName if they need to, or they can create a new instance.

Specified by:

getOrCreateProducer in interface IChannelFactory

Parameters:

theChannelName - The actual underlying queue name

theMessageType - The object type that will be placed on this queue. Objects will be Jackson-annotated structures.

theChannelSettings - Contains the configuration for senders.

getChannelNamer

public IChannelNamer getChannelNamer()

Specified by:

getChannelNamer in interface IChannelFactory

Returns:

the IChannelNamer used by this factory

stop

@PreDestroy
public void stop()