Package edu.internet2.middleware.grouperClient.messaging

Class GrouperMessagingEngine

java.lang.Object
edu.internet2.middleware.grouperClient.messaging.GrouperMessagingEngine
public class GrouperMessagingEngine extends Object
engine sends, receives, marks messages complete

  • Constructor Details

    • GrouperMessagingEngine

      public GrouperMessagingEngine()

  • Method Details

    • send

      public static GrouperMessageSendResult send(GrouperMessageSendParam grouperMessageSendParam)
      send one or more messages
      Parameters:
      grouperMessageSendParam - parameters to send message
      Returns:
      result

    • retrieveGrouperMessageSystemName

      public static String retrieveGrouperMessageSystemName(GrouperMessageSystemParam grouperMessageSystemConfig)
      Parameters:
      grouperMessageSystemConfig -
      Returns:
      the string

    • retrieveGrouperMessageSystem

      public static GrouperMessagingSystem retrieveGrouperMessageSystem(String grouperMessageSystemName)
      Parameters:
      grouperMessageSystemName -
      Returns:
      the system

    • receive

      public static GrouperMessageReceiveResult receive(GrouperMessageReceiveParam grouperMessageReceiveParam)
      this will generally block until there are messages to process. These messages are ordered in the order that they were sent.
      Parameters:
      grouperMessageReceiveParam - param to receive messages
      Returns:
      a message or multiple messages. It will block until there are messages available for this recipient to process

    • acknowledge

      public static GrouperMessageAcknowledgeResult acknowledge(GrouperMessageAcknowledgeParam grouperMessageAcknowledgeParam)
      mark messages that we received and processed, or return to queue, or whatever
      Parameters:
      grouperMessageAcknowledgeParam -
      Returns:
      result