Package | Description |
---|---|
org.wso2.carbon.andes.core | |
org.wso2.carbon.andes.core.internal.registry | |
org.wso2.carbon.andes.core.internal.util |
Modifier and Type | Method and Description |
---|---|
void |
QueueManagerServiceImpl.addQueueAndAssignPermission(String queueName,
QueueRolePermission[] queueRolePermissions)
Create a queue and assign permissions which could be be pub, consume, change permission and etc.
|
void |
QueueManagerService.addQueueAndAssignPermission(String queueName,
QueueRolePermission[] queueRolePermissions)
Create a queue and assign permissions which could be be pub, consume, change permission and etc.
|
Message[] |
QueueManagerServiceImpl.browseQueue(String nameOfQueue,
long nextMessageIdToRead,
int maxMsgCount)
Gets the messages of a queue
|
Message[] |
QueueManagerService.browseQueue(String nameOfQueue,
long nextMessageIdToRead,
int maxMsgCount)
Gets the messages of a queue
|
void |
QueueManagerServiceImpl.createQueue(String queueName)
Creates a new queue
|
void |
QueueManagerService.createQueue(String queueName)
Creates a new queue
|
void |
QueueManagerServiceImpl.deleteMessagesFromDeadLetterQueue(long[] messageIDs,
String destinationQueueName)
Delete messages from the Dead Letter Queue and delete their content.
|
void |
QueueManagerService.deleteMessagesFromDeadLetterQueue(long[] messageIDs,
String destinationQueueName)
Delete messages from the Dead Letter Queue and delete their content.
|
void |
QueueManagerServiceImpl.deleteQueue(String queueName)
This method is triggered when deleting a queue through management console.
|
void |
QueueManagerService.deleteQueue(String queueName)
This method is triggered when deleting a queue through management console.
|
void |
QueueManagerServiceImpl.deleteTopicFromRegistry(String topicName,
String subscriptionId)
This method is triggered unsubscribe from a durable subscription to delete topic related
entries from registry
|
void |
QueueManagerService.deleteTopicFromRegistry(String topicName,
String subscriptionId)
This method is triggered unsubscribe from a durable subscription to delete topic related
entries from registry
|
List<Queue> |
QueueManagerServiceImpl.getAllQueues()
Gets all the queues
|
List<Queue> |
QueueManagerService.getAllQueues()
Gets all the queues
|
String[] |
QueueManagerServiceImpl.getBackendRoles()
Gets roles except for admin
|
String[] |
QueueManagerService.getBackendRoles()
Gets roles except for admin
|
Queue |
QueueManagerServiceImpl.getDLCQueue(String tenantDomain)
Retrieve the dlc queue associated to a tenant
|
Queue |
QueueManagerService.getDLCQueue(String tenantDomain)
Retrieve the dlc queue associated to a tenant
|
long |
QueueManagerServiceImpl.getMessageCount(String destinationName,
String msgPattern)
Gets the message count for a queue
|
long |
QueueManagerService.getMessageCount(String destinationName,
String msgPattern)
Gets the message count for a queue
|
Message[] |
QueueManagerServiceImpl.getMessageMetadataInDLC(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[] |
QueueManagerService.getMessageMetadataInDLC(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[] |
QueueManagerServiceImpl.getMessagesInDLCForQueue(String queueName,
long nextMessageIdToRead,
int maxMessageCount)
Gets the messages in the DLC for a specific queue.
|
Message[] |
QueueManagerService.getMessagesInDLCForQueue(String queueName,
long nextMessageIdToRead,
int maxMessageCount)
Gets the messages in the DLC for a specific queue.
|
Set<String> |
QueueManagerServiceImpl.getNamesOfAllDurableQueues() |
Set<String> |
QueueManagerService.getNamesOfAllDurableQueues()
Retrieve names of all durable queues created
|
long |
QueueManagerServiceImpl.getNumberOfMessagesInDLCForQueue(String queueName)
Gets the number of messages in DLC for a specific queue.
|
long |
QueueManagerService.getNumberOfMessagesInDLCForQueue(String queueName)
Gets the number of messages in DLC for a specific queue.
|
Queue |
QueueManagerServiceImpl.getQueueByName(String queueName)
Retrieve a queue with the number of the messages remaining by passing the name
|
Queue |
QueueManagerService.getQueueByName(String queueName)
Retrieve a queue with the number of the messages remaining by passing the name
|
QueueRolePermission[] |
QueueManagerServiceImpl.getQueueRolePermission(String queueName)
Gets role permissions assigned to a queue
|
QueueRolePermission[] |
QueueManagerService.getQueueRolePermission(String queueName)
Gets role permissions assigned to a queue
|
long |
QueueManagerServiceImpl.getTotalMessagesInQueue(String nameOfQueue)
Gets total message count in a queue
|
long |
QueueManagerService.getTotalMessagesInQueue(String queueName)
Gets total message count in a queue
|
void |
QueueManagerServiceImpl.purgeMessagesOfQueue(String queueName)
Request broker to clean all messages not awaiting acknowledgement from the given queue.
|
void |
QueueManagerService.purgeMessagesOfQueue(String queueName)
Request broker to clean all messages not awaiting acknowledgement from the given queue.
|
int |
QueueManagerServiceImpl.rerouteMessagesFromDeadLetterChannelForQueue(String sourceQueue,
String targetQueue,
int internalBatchSize)
Restore messages destined for the input sourceQueue into a different targetQueue.
|
int |
QueueManagerService.rerouteMessagesFromDeadLetterChannelForQueue(String sourceQueue,
String targetQueue,
int internalBatchSize)
Restore messages destined for the input sourceQueue into a different targetQueue.
|
long |
QueueManagerServiceImpl.rerouteSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String newDestinationQueueName,
String destinationQueueName)
Restore messages from the Dead Letter Queue to another queue in the same tenant.
|
long |
QueueManagerService.rerouteSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String newDestinationQueueName,
String destinationQueueName)
Restore messages from the Dead Letter Queue to another queue in the same tenant.
|
long |
QueueManagerServiceImpl.restoreSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String destinationQueueName)
Restore messages from the Dead Letter Queue to their original queues.
|
long |
QueueManagerService.restoreSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String destinationQueueName)
Restore messages from the Dead Letter Queue to their original queues.
|
boolean |
QueueManagerServiceImpl.sendMessage(String nameOfQueue,
String userName,
String accessKey,
String jmsType,
String jmsCorrelationID,
int numberOfMessages,
String message,
int deliveryMode,
int priority,
long expireTime)
Send a message to the queue
|
boolean |
QueueManagerService.sendMessage(String nameOfQueue,
String userName,
String accessKey,
String jmsType,
String jmsCorrelationID,
int numberOfMessages,
String message,
int deliveryMode,
int priority,
long expireTime)
Send a message to the queue
|
void |
QueueManagerServiceImpl.updatePermission(String queueName,
QueueRolePermission[] queueRolePermissions)
Updates permission for a queue.
|
void |
QueueManagerService.updatePermission(String queueName,
QueueRolePermission[] queueRolePermissions)
Updates permission for a queue.
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
QueueManagementBeans.browseQueue(String queueName,
long nextMessageIdToRead,
int maxMessageCount)
Invoke service bean to retrieve browse messages list
|
void |
QueueManagementBeans.createQueue(String queueName,
String userName)
Invoke service bean to creates a new queue.
|
void |
QueueManagementBeans.deleteMessagesFromDeadLetterQueue(long[] messageIDs,
String destinationQueueName)
Invoke service bean for permanently deleting messages from the Dead Letter Channel.
|
void |
QueueManagementBeans.deleteQueue(String queueName)
Deletes a queue.
|
List<Queue> |
QueueManagementBeans.getAllQueueCounts()
Invoke service bean to get the message count of each queue stored
|
Queue |
QueueManagementBeans.getDLCQueue(String DLCQueueName)
Get DLC queue registered in broker by given name (tenant information included)
|
long |
QueueManagementBeans.getMessageCount(String queueName,
String msgPattern)
Invoke service bean to get the message count for a destination.
|
Set<String> |
QueueManagementBeans.getNamesOfAllDurableQueues()
Invoke service bean to retrieve names of all durable queues
|
void |
QueueManagementBeans.purgeMessagesFromQueue(String queueName,
String userName)
Invoke service bean to delete all messages of a queue.
|
static boolean |
QueueManagementBeans.queueExists(String queueName)
Invoke service bean to check whether a queue exists.
|
long |
QueueManagementBeans.rerouteSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String newDestinationQueueName,
String destinationQueueName)
Invoke service bean for restoring messages from Dead Letter Channel to a given destination.
|
long |
QueueManagementBeans.restoreSelectedMessagesFromDeadLetterChannel(long[] messageIDs,
String destinationQueueName)
Invoke service bean for restoring messages from Dead Letter Channel to their original destinations.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
Utils.isAdmin(String username)
Checks if a given user has admin privileges.
|
Copyright © 2019 WSO2. All rights reserved.