Package ca.uhn.fhir.broker.jms

Class SpringMessagingProducerAdapter<T>

java.lang.Object

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

Type Parameters:

T - the type of payload this message producer is expecting to send

All Implemented Interfaces:

IChannelProducer<T>

public class SpringMessagingProducerAdapter<T>
extends Object
implements IChannelProducer<T>

Adapt a Spring Messaging (JMS) Queue to IChannelProducer

Constructor Summary

Constructors

Constructor	Description
SpringMessagingProducerAdapter(Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>> theMessageType, ISpringMessagingChannelProducer theSpringMessagingChannelProducer)

Method Summary

Modifier and Type	Method	Description
void	addInterceptor(org.springframework.messaging.support.ChannelInterceptor theInterceptor)
String	getChannelName()
Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>>	getMessageType()
ISpringMessagingChannelProducer	getSpringMessagingProducer()
ISendResult	send(ca.uhn.fhir.rest.server.messaging.IMessage<T> theMessage)	Send a message to the broker.

Methods inherited from class java.lang.Object

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

Constructor Details

SpringMessagingProducerAdapter

public SpringMessagingProducerAdapter(Class<? extends ca.uhn.fhir.rest.server.messaging.IMessage<T>> theMessageType,
 ISpringMessagingChannelProducer theSpringMessagingChannelProducer)

Method Details

getChannelName

public String getChannelName()

Specified by:

getChannelName in interface IChannelProducer<T>

Returns:

the name of the topic or queue that this producer is sending messages to

send

public ISendResult send(ca.uhn.fhir.rest.server.messaging.IMessage<T> theMessage)

Description copied from interface: IChannelProducer

Send a message to the broker.

Specified by:

send in interface IChannelProducer<T>

Parameters:

theMessage - the message to send

Returns:

the result of the send operation

addInterceptor

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

getSpringMessagingProducer

public ISpringMessagingChannelProducer getSpringMessagingProducer()

getMessageType

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