Modifier and Type | Method and Description |
---|---|
void |
TopicManagerService.addTopic(String topicName)
Adds a new topic
|
boolean |
TopicManagerService.checkUserHasAddTopicPermission(String username)
Check if given user has add topic permission.
|
boolean |
TopicManagerService.checkUserHasDeleteTopicPermission(String username)
Check if given user has delete topic permission.
|
boolean |
TopicManagerService.checkUserHasDetailsTopicPermission(String username)
Check if given user has permission to view topic details.
|
boolean |
TopicManagerService.checkUserHasPublishTopicPermission(String topicName,
String username)
Check if given user has permission to publish to topic.
|
List<Subscription> |
EventBroker.getAllSubscriptions(String filter)
Get all subscriptions
|
String[] |
TopicManagerService.getBackendRoles()
Get array of backend roles excluding admin and wso2.anonymous.role roles
|
Subscription[] |
TopicManagerService.getJMSSubscriptions(String topicName)
Gets the JMS subscriptions for a given topic
|
TopicNode |
TopicManagerService.getPaginatedTopicTree(String topicPath,
int startIndex,
int numberOfTopicsPerRound)
Get the paginated topic tree.
|
Subscription |
EventBroker.getSubscription(String id)
Get subscription from subscription ID
|
Subscription[] |
TopicManagerService.getSubscriptions(String topicName,
boolean withChildren)
Gets subscriptions for a topic
|
TopicManagerService |
EventBroker.getTopicManagerService()
Gets the topic manager
|
TopicRolePermission[] |
TopicManagerService.getTopicRolePermission(String topicName)
Gets the permissions for topic
|
TopicNode |
TopicManagerService.getTopicTree()
Gets the topic tree.
|
void |
EventBroker.initializeTenant()
This method is called when a tenant initialize.
|
boolean |
TopicManagerService.isTopicExists(String topicName)
Checks whether topic exists
|
void |
EventBroker.publish(Message message,
String topicName)
Publish an event to the given topic asynchronously.
|
void |
EventBroker.publish(Message message,
String topicName,
int deliveryMode)
Publish an event to the given topic asynchronously.
|
void |
EventBroker.publishRobust(Message message,
String topicName)
Publish an event to the given topic synchronously.
|
void |
EventBroker.publishRobust(Message message,
String topicName,
int deliveryMode)
Publish an event to the given topic synchronously.
|
boolean |
TopicManagerService.removeTopic(String topicName)
Removes a topic
|
void |
EventBroker.renewSubscription(Subscription subscription)
Renews a subscription.
|
void |
NotificationManager.sendNotification(Message message,
Subscription subscription)
Notification message send to given subscription
|
String |
EventBroker.subscribe(Subscription subscription)
Subscribe using the given subscription details.
|
void |
EventBroker.unsubscribe(String id)
Unsubscribes a subscription
|
void |
TopicManagerService.updatePermissions(String topicName,
TopicRolePermission[] topicRolePermissions)
Update permissions for a topic
|
Modifier and Type | Method and Description |
---|---|
void |
DeliveryManager.cleanUp()
Clear subscription details
|
void |
DeliveryManager.initializeTenant()
Initialize tenant
|
void |
DeliveryManager.publish(Message message,
String topicName,
int deliveryMode)
publish an omElement to a topic
|
void |
DeliveryManager.renewSubscription(Subscription subscription)
Renew subscription details
|
void |
DeliveryManager.subscribe(Subscription subscription)
subscribe with the subscription details.
|
void |
DeliveryManager.unSubscribe(String id)
un-subscribe the subscription
|
Modifier and Type | Class and Description |
---|---|
class |
EventBrokerConfigurationException
Event broker building logic throws this exception to any configuration problem.
|
Modifier and Type | Method and Description |
---|---|
void |
CarbonEventBroker.cleanUp()
Cleans up the delivery broker
|
List<Subscription> |
CarbonEventBroker.getAllSubscriptions(String filter)
Get all subscriptions
|
Subscription |
CarbonEventBroker.getSubscription(String id)
Get subscription from subscription ID
|
void |
CarbonEventBroker.initializeTenant()
This method is called when a tenant initialize.
|
void |
CarbonEventBroker.publish(Message message,
String topicName)
Publish an event to the given topic asynchronously.
|
void |
CarbonEventBroker.publish(Message message,
String topicName,
int deliveryMode)
Publish an event to the given topic asynchronously.
|
void |
CarbonEventBroker.publishRobust(Message message,
String topicName)
Publish an event to the given topic synchronously.
|
void |
CarbonEventBroker.publishRobust(Message message,
String topicName,
int deliveryMode)
Publish an event to the given topic synchronously.
|
void |
CarbonEventBroker.renewSubscription(Subscription subscription)
Renews a subscription.
|
String |
CarbonEventBroker.subscribe(Subscription subscription)
Subscribe using the given subscription details.
|
void |
CarbonEventBroker.unsubscribe(String id)
Unsubscribes a subscription
|
Modifier and Type | Method and Description |
---|---|
void |
JMSDeliveryManager.cleanUp()
Clear subscription details
|
void |
JMSSubscriptionDetails.close() |
javax.jms.TopicConnection |
JMSDeliveryManager.getTopicConnection(String userName)
Initialize and return topic connection
|
protected abstract javax.jms.TopicConnectionFactory |
JMSDeliveryManager.getTopicConnectionFactory(InitialContext initialContext)
Return topic connection factory for given initial context properties
|
protected javax.jms.TopicConnectionFactory |
QpidJMSDeliveryManager.getTopicConnectionFactory(InitialContext initialContext)
Return topic connection factory for given initial context properties
|
void |
JMSDeliveryManager.initializeTenant()
Initialize tenant
|
void |
JMSDeliveryManager.publish(Message message,
String topicName,
int deliveryMode)
publish an omElement to a topic
|
void |
JMSDeliveryManager.renewSubscription(Subscription subscription)
Renew subscription details
|
void |
JMSDeliveryManager.subscribe(Subscription subscription)
subscribe with the subscription details.
|
void |
JMSDeliveryManager.unSubscribe(String id)
un-subscribe the subscription
|
Modifier and Type | Method and Description |
---|---|
void |
CarbonNotificationManager.sendNotification(Message message,
Subscription subscription)
Notification message send to given subscription
|
Modifier and Type | Method and Description |
---|---|
void |
RegistrySubscriptionManager.addSubscription(Subscription subscription)
When adding a subscription first it stores in the registry as as set of property values
then add the subscription details to the topic index
|
void |
TopicManagerServiceImpl.addTopic(String topicName)
Adding topic, when creating topics from the user interface
Adds a new topic
|
boolean |
TopicManagerServiceImpl.checkUserHasAddTopicPermission(String username)
Check if given user has add topic permission.
|
boolean |
TopicManagerServiceImpl.checkUserHasDeleteTopicPermission(String username)
Check if given user has delete topic permission.
|
boolean |
TopicManagerServiceImpl.checkUserHasDetailsTopicPermission(String username)
Check if given user has permission to view topic details.
|
boolean |
TopicManagerServiceImpl.checkUserHasPublishTopicPermission(String topicName,
String username)
Check if given user has permission to publish to topic.
|
List<Subscription> |
RegistrySubscriptionManager.getAllSubscriptions()
Get all the subscriptions.
|
String[] |
TopicManagerServiceImpl.getBackendRoles()
Get array of backend roles excluding admin and wso2.anonymous.role roles
|
Subscription[] |
TopicManagerServiceImpl.getJMSSubscriptions(String topicName)
Gets the JMS subscriptions for a given topic
|
TopicNode |
TopicManagerServiceImpl.getPaginatedTopicTree(String topicPath,
int startIndex,
int numberOfTopicsPerRound)
Get the paginated topic tree.
|
Subscription |
RegistrySubscriptionManager.getSubscription(String id)
Gets the subscription
|
Subscription[] |
TopicManagerServiceImpl.getSubscriptions(String topicName,
boolean withChildren)
Gets subscriptions for a topic
|
TopicRolePermission[] |
TopicManagerServiceImpl.getTopicRolePermission(String topicName)
Gets the permissions for topic
|
String |
RegistrySubscriptionManager.getTopicStoragePath()
Gets the topic storage path
|
TopicNode |
TopicManagerServiceImpl.getTopicTree()
Gets the topic tree.
|
boolean |
TopicManagerServiceImpl.isTopicExists(String topicName)
Checks whether topic exists
|
boolean |
TopicManagerServiceImpl.removeTopic(String topicName)
Removes a topic
|
void |
RegistrySubscriptionManager.renewSubscription(Subscription subscription)
Renewing a subscription
|
void |
RegistrySubscriptionManager.unSubscribe(String subscriptionID)
Un-Subscribing to a destination.
|
void |
TopicManagerServiceImpl.updatePermissions(String topicName,
TopicRolePermission[] topicRolePermissions)
Update permissions for a topic
|
Modifier and Type | Method and Description |
---|---|
static boolean |
JavaUtil.isAdmin(String username)
Check if the given user has the admin role
|
Modifier and Type | Method and Description |
---|---|
void |
SubscriptionManager.addSubscription(Subscription subscription)
When adding a subscription first it stores in the registry as as set of property values
then add the subscription details to the topic index
|
List<Subscription> |
SubscriptionManager.getAllSubscriptions()
Get all the subscriptions.
|
Subscription |
SubscriptionManager.getSubscription(String id)
Gets the subscription
|
String |
SubscriptionManager.getTopicStoragePath()
Gets the topic storage path
|
void |
SubscriptionManager.renewSubscription(Subscription subscription)
Renewing a subscription
|
void |
SubscriptionManager.unSubscribe(String subscriptionID)
Un-Subscribing to a destination.
|
Copyright © 2018 WSO2. All rights reserved.