Package edu.internet2.middleware.grouper.messaging

Class GrouperBuiltinMessagingSystem

java.lang.Object
edu.internet2.middleware.grouper.messaging.GrouperBuiltinMessagingSystem
All Implemented Interfaces:
GrouperMessagingSystem
public class GrouperBuiltinMessagingSystem extends Object implements GrouperMessagingSystem
built in messaging system from database

  • Field Details

  • Constructor Details

    • GrouperBuiltinMessagingSystem

      public GrouperBuiltinMessagingSystem()

  • Method Details

    • messageRootStemName

      public static String messageRootStemName()
      message root stem
      Returns:
      the message root stem

    • grouperMessageTopicNameOfDef

      public static String grouperMessageTopicNameOfDef()
      grouper message topic name of attribute def
      Returns:
      the name

    • grouperMessageNameOfRole

      public static String grouperMessageNameOfRole()
      grouper message name of role
      Returns:
      the name

    • grouperMessageQueueNameOfDef

      public static String grouperMessageQueueNameOfDef()
      grouper message queue name of attribute def
      Returns:
      the name

    • topicStemName

      public static String topicStemName()
      topic stem name
      Returns:
      topic stem name GrouperBuiltinMessagingSystem.

    • queueStemName

      public static String queueStemName()
      queue stem name GrouperBuiltinMessagingSystem.
      Returns:
      queue stem name

    • createTopic

      public static boolean createTopic(String topicName)
      Parameters:
      topicName -
      Returns:
      if created or already existed

    • deleteTopic

      public static boolean deleteTopic(String topicName)
      Parameters:
      topicName -
      Returns:
      if deleted or didnt exist

    • deleteQueue

      public static boolean deleteQueue(String queueName)
      Parameters:
      queueName -
      Returns:
      if deleted or didnt exist

    • createQueue

      public static boolean createQueue(String queueName)
      Parameters:
      queueName -
      Returns:
      if created or already created

    • topicAddSendToQueue

      public static boolean topicAddSendToQueue(String topicName, String queueName)
      Parameters:
      topicName -
      queueName -
      Returns:
      true if a change occurred

    • topicRemoveSendToQueue

      public static boolean topicRemoveSendToQueue(String topicName, String queueName)
      Parameters:
      topicName -
      queueName -
      Returns:
      true if a change occurred

    • allowSendToTopic

      public static boolean allowSendToTopic(String topicName, Subject subject)
      Parameters:
      topicName -
      subject -
      Returns:
      true if assigned or false if already existed

    • disallowSendToTopic

      public static boolean disallowSendToTopic(String topicName, Subject subject)
      Parameters:
      topicName -
      subject -
      Returns:
      true if assigned or false if already existed

    • allowSendToQueue

      public static boolean allowSendToQueue(String queueName, Subject subject)
      Parameters:
      queueName -
      subject -
      Returns:
      true if changed, false if not

    • disallowSendToQueue

      public static boolean disallowSendToQueue(String queueName, Subject subject)
      Parameters:
      queueName -
      subject -
      Returns:
      true if changed, false if not

    • allowReceiveFromQueue

      public static boolean allowReceiveFromQueue(String queueName, Subject subject)
      Parameters:
      queueName -
      subject -
      Returns:
      true if changed or false if not changed

    • disallowReceiveFromQueue

      public static boolean disallowReceiveFromQueue(String queueName, Subject subject)
      Parameters:
      queueName -
      subject -
      Returns:
      true if changed or false if not changed

    • allowedToSendToQueue

      public static boolean allowedToSendToQueue(String queueName, Subject subject)
      Parameters:
      queueName -
      subject -
      Returns:
      true if allowed to send to queue

    • allowedToReceiveFromQueue

      public static boolean allowedToReceiveFromQueue(String queueName, Subject subject)
      Parameters:
      queueName -
      subject -
      Returns:
      true if allowed to send to queue

    • allowedToSendToTopic

      public static boolean allowedToSendToTopic(String topicName, Subject subject)
      Parameters:
      topicName -
      subject -
      Returns:
      true if allowed to send to topic

    • queuesTopicSendsTo

      public static Collection<String> queuesTopicSendsTo(String topicName)
      Parameters:
      topicName -
      Returns:
      the queue names that the topic sends to

    • messageSentTimeMicros

      public static long messageSentTimeMicros()
      get a change log id
      Returns:
      a change log id value

    • cleanOldUnprocessedMessages

      public static int cleanOldUnprocessedMessages()
      clean old unprocessed messages
      Returns:
      the number of messages affected

    • cleanOldProcessedMessages

      public static int cleanOldProcessedMessages()
      clean old unprocessed messages
      Returns:
      the number of messages affected

    • send

      public GrouperMessageSendResult send(GrouperMessageSendParam grouperMessageSendParam)
      Specified by:
      send in interface GrouperMessagingSystem
      See Also:

    • receive

      public GrouperMessageReceiveResult receive(GrouperMessageReceiveParam grouperMessageReceiveParam)
      Specified by:
      receive in interface GrouperMessagingSystem
      See Also:

    • acknowledge

      public GrouperMessageAcknowledgeResult acknowledge(GrouperMessageAcknowledgeParam grouperMessageAcknowledgeParam)
      Specified by:
      acknowledge in interface GrouperMessagingSystem
      See Also: