Package | Description |
---|---|
org.wso2.carbon.andes.admin |
Modifier and Type | Method and Description |
---|---|
void |
AndesAdminService.addQueueAndAssignPermission(String queueName,
QueueRolePermission[] queueRolePermissionsDTO)
Add a queue with the given name and assign permissions
|
Message[] |
AndesAdminService.browseQueue(String queueName,
long nextMessageIdToRead,
int maxMsgCount)
Browse the given queue name by start index and max messages count
|
boolean |
AndesAdminService.checkCurrentUserHasAddQueuePermission()
Check if current user has add permission.
|
boolean |
AndesAdminService.checkCurrentUserHasBrowseMessagesInDLCPermission()
Check if current user has browse messages in dlc permission.
|
boolean |
AndesAdminService.checkCurrentUserHasBrowseQueuePermission()
Check if current user has browse permission.
|
boolean |
AndesAdminService.checkCurrentUserHasDeleteMessagesInDLCPermission()
Check if current user has delete messages in dlc permission.
|
boolean |
AndesAdminService.checkCurrentUserHasDeleteQueuePermission()
Check if current user has delete permission.
|
boolean |
AndesAdminService.checkCurrentUserHasPublishPermission(String queueName)
Check if current user is has publish permission for a queue.
|
boolean |
AndesAdminService.checkCurrentUserHasPurgeQueuePermission()
Check if current user has purge permission.
|
boolean |
AndesAdminService.checkCurrentUserHasQueueSubscriptionClosePermission()
Evaluate current logged in user has close subscription permission for queue subscriptions .
|
boolean |
AndesAdminService.checkCurrentUserHasRerouteMessagesInDLCPermission()
Check if current user has reroute messages in dlc permission.
|
boolean |
AndesAdminService.checkCurrentUserHasRestoreMessagesInDLCPermission()
Check if current user has restore messages in dlc permission.
|
boolean |
AndesAdminService.checkCurrentUserHasTopicSubscriptionClosePermission()
Evaluate current logged in user has close subscription permission for topic subscriptions.
|
boolean |
AndesAdminService.checkUserHasAddQueuePermission(String username)
Check if given user has add permission.
|
boolean |
AndesAdminService.checkUserHasBrowseMessagesInDLCPermission(String username)
Check if given user has browse messages in dlc permission.
|
boolean |
AndesAdminService.checkUserHasBrowseQueuePermission(String username)
Check if given user has browse permission.
|
boolean |
AndesAdminService.checkUserHasDeleteMessagesInDLCPermission(String username)
Check if given user has delete messages in dlc permission.
|
boolean |
AndesAdminService.checkUserHasDeleteQueuePermission(String username)
Check if given user has delete permission.
|
boolean |
AndesAdminService.checkUserHasPublishPermission(String queueName,
String userName)
Check if a user has publishing permission for a queue.
|
boolean |
AndesAdminService.checkUserHasPurgeQueuePermission(String username)
Check if given user has purge permission.
|
boolean |
AndesAdminService.checkUserHasRerouteMessagesInDLCPermission(String username)
Check if given user has reroute messages in dlc permission.
|
boolean |
AndesAdminService.checkUserHasRestoreMessagesInDLCPermission(String username)
Check if given user has restore messages in dlc permission.
|
void |
AndesAdminService.closeSubscription(boolean isDurable,
String subscriptionID,
String subscribedQueueOrTopicName,
String protocolType,
String destinationType,
String subscriberQueueName)
Close subscription defined by subscription ID forcibly
|
void |
AndesAdminService.deleteMessagesFromDeadLetterQueue(long[] messageIDs,
String destinationQueueName)
Delete messages from the Dead Letter Queue and delete their content.
|
void |
AndesAdminService.deleteQueue(String queueName)
Deletes a queue.
|
void |
AndesAdminService.deleteTopicFromRegistry(String topicName,
String subscriptionId)
Delete topic related resources from registry
|
void |
AndesAdminService.dumpMessageStatus()
Invoke MBean operations and dump status of all messages.
|
Queue[] |
AndesAdminService.getAllQueues()
Gets all queues.
|
Subscription[] |
AndesAdminService.getAllSubscriptions()
Gets all subscriptions.
|
Queue |
AndesAdminService.getDLCQueue()
Retrieve the DLC queue for the domain
|
Subscription[] |
AndesAdminService.getFilteredSubscriptions(boolean isDurable,
boolean isActive,
String protocolType,
String destinationType,
String filteredNamePattern,
boolean isFilteredNameByExactMatch,
String identifierPattern,
boolean isIdentifierPatternByExactMatch,
String ownNodeId,
int pageNumber,
int subscriptionCountPerPage)
Retrieve subscriptions matching to the given search criteria.
|
long |
AndesAdminService.getMessageCount(String destinationName,
String msgPattern)
Gets the message count for a queue
Suppressing 'UnusedDeclaration' as it is called by webservice
|
int |
AndesAdminService.getMessageCountForSubscriber(String subscriptionID,
boolean durable,
String protocolType,
String destinationType)
Gets the number of messages remaining for a subscriber.
|
Message[] |
AndesAdminService.getMessageMetadataInDeadLetterChannel(String targetQueue,
long startMessageId,
int pageLimit)
Returns a paginated list of message metadata destined for the inputQueueName but currently living in the
Dead Letter Channel.
|
Message[] |
AndesAdminService.getMessagesInDLCForQueue(String queueName,
long nextMessageIdToRead,
int maxMsgCount)
Gets the number of messages in DLC fora given queue name by start index and max messages
count
|
Set<String> |
AndesAdminService.getNamesOfAllDurableQueues()
Get a list of names of durable queues created in the broker
|
long |
AndesAdminService.getNumberOfMessagesInDLCForQueue(String queueName)
Gets the number of messages in DLC belonging to a specific queue.
|
long |
AndesAdminService.getPendingMessageCount(String queueName)
Get the pending message count for the specified subscription
|
Queue |
AndesAdminService.getQueueByName(String queueName)
Retrieve an
Queue with the number of messages remaining in the
database by passing a queue name |
QueueRolePermission[] |
AndesAdminService.getQueueRolePermission(String queueName)
Get all permission of the given queue name
|
Subscription[] |
AndesAdminService.getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
Retrieve subscriptions matching the given criteria.
|
long |
AndesAdminService.getTotalMessagesInQueue(String queueName)
Total messages in the given queue
|
int |
AndesAdminService.getTotalSubscriptionCountForSearchResult(boolean isDurable,
boolean isActive,
String protocolType,
String destinationType,
String filteredNamePattern,
boolean isFilteredNameByExactMatch,
String identifierPattern,
boolean isIdentifierPatternByExactMatch,
String ownNodeId)
Returns the total subscription count relevant to a particular search criteria.
|
String[] |
AndesAdminService.getUserRoles()
Get roles of the current logged user
If user has admin role, then all available roles will be return
|
void |
AndesAdminService.purgeMessagesOfQueue(String queueName)
Deletes all messages from a queue.
|
String |
AndesAdminService.rerouteAllMessagesFromDeadLetterChannelForQueue(String sourceQueue,
String targetQueue,
int internalBatchSize)
Move messages destined for the input sourceQueue into a different targetQueue.
|
long |
AndesAdminService.rerouteSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String newDestinationQueueName,
String destinationQueueName)
Restore messages from the Dead Letter Queue to another queue in the same tenant.
|
long |
AndesAdminService.restoreSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String destinationQueueName)
Restore messages from the Dead Letter Queue to their original queues.
|
boolean |
AndesAdminService.sendMessage(String queueName,
String jmsType,
String jmsCorrelationID,
int numberOfMessages,
String message,
int deliveryMode,
int priority,
long expireTime)
Send messages to given queue
|
void |
AndesAdminService.updatePermission(String queueName,
QueueRolePermission[] queueRolePermissionsDTO)
Update the permission of the given queue name
|
Copyright © 2018 WSO2. All rights reserved.