Package ca.uhn.fhir.broker.impl

Class MultiplexingListener<T>

java.lang.Object

ca.uhn.fhir.broker.impl.MultiplexingListener<T>

Type Parameters:

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

All Implemented Interfaces:

IMessageListener<T>, IRetryAwareMessageListener<T>, AutoCloseable

public class MultiplexingListener<T>
extends Object
implements IRetryAwareMessageListener<T>, AutoCloseable

This message listener delegates message handling to an ordered list of sub-listeners. It supports message handling within a retry-aware context.

Constructor Summary

Constructors

Constructor	Description
MultiplexingListener(Class<T> thePayloadType)

Method Summary

Modifier and Type	Method	Description
boolean	addListener(IMessageListener<T> theListener)
void	close()
<L extends IMessageListener<T>> L	getListenerOfTypeOrNull(Class<L> theMessageListenerClass)
Class<T>	getPayloadType()
void	handleMessage(ca.uhn.fhir.rest.server.messaging.IMessageDeliveryContext theMessageDeliveryContext, ca.uhn.fhir.rest.server.messaging.IMessage<T> theMessage)	This method is called whenever a new message is received.
boolean	removeListener(IMessageListener<T> theListener)

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.IRetryAwareMessageListener

handleMessage

Constructor Details

MultiplexingListener

public MultiplexingListener(Class<T> thePayloadType)

Method Details

handleMessage

public void handleMessage(@Nullable
 ca.uhn.fhir.rest.server.messaging.IMessageDeliveryContext theMessageDeliveryContext,
 @Nonnull
 ca.uhn.fhir.rest.server.messaging.IMessage<T> theMessage)

Description copied from interface: IRetryAwareMessageListener

This method is called whenever a new message is received.

Specified by:

handleMessage in interface IRetryAwareMessageListener<T>

Parameters:

theMessageDeliveryContext - details about the message delivery if available

theMessage - the message that was received

getPayloadType

public Class<T> getPayloadType()

Specified by:

getPayloadType in interface IMessageListener<T>

Returns:

the type of payload this message listener is expecting to receive

addListener

public boolean addListener(IMessageListener<T> theListener)

removeListener

public boolean removeListener(IMessageListener<T> theListener)

close

public void close()

Specified by:

close in interface AutoCloseable

getListenerOfTypeOrNull

public <L extends IMessageListener<T>> L getListenerOfTypeOrNull(Class<L> theMessageListenerClass)