Package ca.uhn.fhir.broker.jms

Class SpringMessagingReceiverAdapter<T>

java.lang.Object

ca.uhn.fhir.broker.jms.SpringMessagingReceiverAdapter<T>

Type Parameters:

T - the type of payload this message consumer is expecting to receive

All Implemented Interfaces:

IChannelConsumer<T>, AutoCloseable

public class SpringMessagingReceiverAdapter<T>
extends Object
implements IChannelConsumer<T>

Adapt a Spring Messaging (JMS) Queue to IChannelConsumer

Constructor Summary

Constructors

Constructor	Description
SpringMessagingReceiverAdapter(Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>> theMessageType, ISpringMessagingChannelReceiver theSpringMessagingChannelReceiver, IMessageListener<T> theMessageListener)

Method Summary

Modifier and Type	Method	Description
void	close()	Close this consumer's listener and this consumer, releasing any resources.
String	getChannelName()
IMessageListener<T>	getMessageListener()
Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>>	getMessageType()
ISpringMessagingChannelReceiver	getSpringMessagingChannelReceiver()
boolean	isClosed()
void	pause()	Pause requesting new messages from the broker until resume() is called.
void	resume()	Resume requesting messages from the broker.
void	start()	Start the thread(s) that will be consuming messages
void	subscribe(org.springframework.messaging.MessageHandler theMessageHandler)

Methods inherited from class java.lang.Object

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

Methods inherited from interface ca.uhn.fhir.broker.api.IChannelConsumer

checkState

Constructor Details

SpringMessagingReceiverAdapter

public SpringMessagingReceiverAdapter(Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>> theMessageType,
 ISpringMessagingChannelReceiver theSpringMessagingChannelReceiver,
 IMessageListener<T> theMessageListener)

Method Details

subscribe

public void subscribe(org.springframework.messaging.MessageHandler theMessageHandler)

close

public void close()

Description copied from interface: IChannelConsumer

Close this consumer's listener and this consumer, releasing any resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IChannelConsumer<T>

isClosed

public boolean isClosed()

Specified by:

isClosed in interface IChannelConsumer<T>

Returns:

true if this consumer is closed

getChannelName

public String getChannelName()

Specified by:

getChannelName in interface IChannelConsumer<T>

Returns:

the name of the topic or queue that this consumer is consuming from

start

public void start()
           throws ChannelConsumerStartFailureException

Description copied from interface: IChannelConsumer

Start the thread(s) that will be consuming messages

Specified by:

start in interface IChannelConsumer<T>

Throws:

ChannelConsumerStartFailureException - if the consumer fails to start (e.g. if it fails to connect to the broker)

getSpringMessagingChannelReceiver

public ISpringMessagingChannelReceiver getSpringMessagingChannelReceiver()

getMessageType

public Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>> getMessageType()

Specified by:

getMessageType in interface IChannelConsumer<T>

Returns:

the type of messages that will be delivered to this consumer

getMessageListener

public IMessageListener<T> getMessageListener()

Specified by:

getMessageListener in interface IChannelConsumer<T>

Returns:

the IMessageListener this consumer is sending messages to (i.e. the one it was created with).

pause

public void pause()

Description copied from interface: IChannelConsumer

Pause requesting new messages from the broker until resume() is called.

Specified by:

pause in interface IChannelConsumer<T>

resume

public void resume()

Description copied from interface: IChannelConsumer

Resume requesting messages from the broker.

Specified by:

resume in interface IChannelConsumer<T>