public class GrouperBuiltinMessagingSystem extends Object implements GrouperMessagingSystem
Modifier and Type | Class and Description |
---|---|
static class |
GrouperBuiltinMessagingSystem.GrouperBuiltinMessageState
state of a message
|
Modifier and Type | Field and Description |
---|---|
static String |
actionReceive
action for receive
|
static String |
actionSendToQueue
action for send to queue
|
static String |
actionSendToTopic
action for send to topic
|
static String |
BUILTIN_NAME
name of built in messaging system
|
Constructor and Description |
---|
GrouperBuiltinMessagingSystem() |
Modifier and Type | Method and Description |
---|---|
GrouperMessageAcknowledgeResult |
acknowledge(GrouperMessageAcknowledgeParam grouperMessageAcknowledgeParam) |
static boolean |
allowedToReceiveFromQueue(String queueName,
Subject subject) |
static boolean |
allowedToSendToQueue(String queueName,
Subject subject) |
static boolean |
allowedToSendToTopic(String topicName,
Subject subject) |
static boolean |
allowReceiveFromQueue(String queueName,
Subject subject) |
static boolean |
allowSendToQueue(String queueName,
Subject subject) |
static boolean |
allowSendToTopic(String topicName,
Subject subject) |
static int |
cleanOldProcessedMessages()
clean old unprocessed messages
|
static int |
cleanOldUnprocessedMessages()
clean old unprocessed messages
|
static boolean |
createQueue(String queueName) |
static boolean |
createTopic(String topicName) |
static boolean |
deleteQueue(String queueName) |
static boolean |
deleteTopic(String topicName) |
static boolean |
disallowReceiveFromQueue(String queueName,
Subject subject) |
static boolean |
disallowSendToQueue(String queueName,
Subject subject) |
static boolean |
disallowSendToTopic(String topicName,
Subject subject) |
static String |
grouperMessageNameOfRole()
grouper message name of role
|
static String |
grouperMessageQueueNameOfDef()
grouper message queue name of attribute def
|
static String |
grouperMessageTopicNameOfDef()
grouper message topic name of attribute def
|
static String |
messageRootStemName()
message root stem
|
static long |
messageSentTimeMicros()
get a change log id
|
static String |
queueStemName()
queue stem name GrouperBuiltinMessagingSystem.
|
static Collection<String> |
queuesTopicSendsTo(String topicName) |
GrouperMessageReceiveResult |
receive(GrouperMessageReceiveParam grouperMessageReceiveParam) |
GrouperMessageSendResult |
send(GrouperMessageSendParam grouperMessageSendParam) |
static boolean |
topicAddSendToQueue(String topicName,
String queueName) |
static boolean |
topicRemoveSendToQueue(String topicName,
String queueName) |
static String |
topicStemName()
topic stem name
|
public static final String actionSendToTopic
public static final String actionSendToQueue
public static final String actionReceive
public static final String BUILTIN_NAME
public static String messageRootStemName()
public static String grouperMessageTopicNameOfDef()
public static String grouperMessageNameOfRole()
public static String grouperMessageQueueNameOfDef()
public static String topicStemName()
public static String queueStemName()
public static boolean createTopic(String topicName)
topicName
- public static boolean deleteTopic(String topicName)
topicName
- public static boolean deleteQueue(String queueName)
queueName
- public static boolean createQueue(String queueName)
queueName
- public static boolean topicAddSendToQueue(String topicName, String queueName)
topicName
- queueName
- public static boolean topicRemoveSendToQueue(String topicName, String queueName)
topicName
- queueName
- public static boolean allowSendToTopic(String topicName, Subject subject)
topicName
- subject
- public static boolean disallowSendToTopic(String topicName, Subject subject)
topicName
- subject
- public static boolean allowSendToQueue(String queueName, Subject subject)
queueName
- subject
- public static boolean disallowSendToQueue(String queueName, Subject subject)
queueName
- subject
- public static boolean allowReceiveFromQueue(String queueName, Subject subject)
queueName
- subject
- public static boolean disallowReceiveFromQueue(String queueName, Subject subject)
queueName
- subject
- public static boolean allowedToSendToQueue(String queueName, Subject subject)
queueName
- subject
- public static boolean allowedToReceiveFromQueue(String queueName, Subject subject)
queueName
- subject
- public static boolean allowedToSendToTopic(String topicName, Subject subject)
topicName
- subject
- public static Collection<String> queuesTopicSendsTo(String topicName)
topicName
- public static long messageSentTimeMicros()
public static int cleanOldUnprocessedMessages()
public static int cleanOldProcessedMessages()
public GrouperMessageSendResult send(GrouperMessageSendParam grouperMessageSendParam)
send
in interface GrouperMessagingSystem
GrouperMessagingSystem.send(edu.internet2.middleware.grouperClient.messaging.GrouperMessageSendParam)
public GrouperMessageReceiveResult receive(GrouperMessageReceiveParam grouperMessageReceiveParam)
receive
in interface GrouperMessagingSystem
GrouperMessagingSystem.receive(GrouperMessageReceiveParam)
public GrouperMessageAcknowledgeResult acknowledge(GrouperMessageAcknowledgeParam grouperMessageAcknowledgeParam)
acknowledge
in interface GrouperMessagingSystem
GrouperMessagingSystem.acknowledge(edu.internet2.middleware.grouperClient.messaging.GrouperMessageAcknowledgeParam)
Copyright © 2016 Internet2. All rights reserved.