Package ca.uhn.fhir.broker.api

Interface IRetryAwareMessageListener<T>

Type Parameters:
T - the type of payload this message listener is expecting to receive
All Superinterfaces:
IMessageListener<T>
All Known Implementing Classes:
MultiplexingListener
public interface IRetryAwareMessageListener<T> extends IMessageListener<T>
This is a message listener that expects to be called within a retrying context

  • Method Details

    • handleMessage

      default void handleMessage(@Nonnull ca.uhn.fhir.rest.server.messaging.IMessage<T> theMessage)
      Use handleMessage(IMessageListener, IMessageDeliveryContext, IMessage) to properly call instances of IRetryAwareMessageListener
      Specified by:
      handleMessage in interface IMessageListener<T>
      Parameters:
      theMessage - the message that was received

    • handleMessage

      void handleMessage(@Nonnull ca.uhn.fhir.rest.server.messaging.IMessageDeliveryContext theMessageDeliveryContext, @Nonnull ca.uhn.fhir.rest.server.messaging.IMessage<T> theMessage)
      This method is called whenever a new message is received.
      Parameters:
      theMessageDeliveryContext - details about the message delivery if available
      theMessage - the message that was received

    • handleMessage

      static <P> void handleMessage(IMessageListener<P> theMessageListener, @Nonnull ca.uhn.fhir.rest.server.messaging.IMessageDeliveryContext theMessageDeliveryContext, ca.uhn.fhir.rest.server.messaging.IMessage<P> theMessage)
      Static helper method to call handleMessage on a message listener when it is not known whether the listener is an instance of IRetryAwareMessageListener
      Type Parameters:
      P - the type of payload this message listener is expecting to receive
      Parameters:
      theMessageListener - the message listener to call
      theMessageDeliveryContext - details about the message delivery if available
      theMessage - the message that was received