- CarbonEventBroker - Class in org.wso2.carbon.andes.event.core.internal
-
The following class contains the carbon eventing implementation related to subscriptions and
topics.
- CarbonEventBroker() - Constructor for class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
- CarbonEventBrokerFactory - Class in org.wso2.carbon.andes.event.core.internal
-
Factory to create new carbon event brokers
- CarbonEventBrokerFactory() - Constructor for class org.wso2.carbon.andes.event.core.internal.CarbonEventBrokerFactory
-
- CarbonNotificationManager - Class in org.wso2.carbon.andes.event.core.internal.notify
-
Notification manager of the carbon.
- CarbonNotificationManager() - Constructor for class org.wso2.carbon.andes.event.core.internal.notify.CarbonNotificationManager
-
- CF_NAME - Static variable in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- CF_NAME_PREFIX - Static variable in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- checkUserHasAddTopicPermission(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Check if given user has add topic permission.
- checkUserHasAddTopicPermission(String) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Check if given user has add topic permission.
- checkUserHasDeleteTopicPermission(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Check if given user has delete topic permission.
- checkUserHasDeleteTopicPermission(String) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Check if given user has delete topic permission.
- checkUserHasDetailsTopicPermission(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Check if given user has permission to view topic details.
- checkUserHasDetailsTopicPermission(String) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Check if given user has permission to view topic details.
- checkUserHasPublishTopicPermission(String, String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Check if given user has permission to publish to topic.
- checkUserHasPublishTopicPermission(String, String) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Check if given user has permission to publish to topic.
- cleanUp() - Method in interface org.wso2.carbon.andes.event.core.delivery.DeliveryManager
-
Clear subscription details
- cleanUp() - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Cleans up the delivery broker
- cleanUp() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Clear subscription details
- close() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSSubscriptionDetails
-
- createEventBroker() - Static method in class org.wso2.carbon.andes.event.core.internal.builder.EventBrokerBuilder
-
- creatingConfigurationContext(int) - Method in class org.wso2.carbon.andes.event.core.internal.builder.EventAxis2ConfigurationContextObserver
-
Initialize configuration context
- getAccessKey() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- getAccessKey() - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- getAllSubscriptions(String) - Method in interface org.wso2.carbon.andes.event.core.EventBroker
-
Get all subscriptions
- getAllSubscriptions(String) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Get all subscriptions
- getAllSubscriptions() - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.RegistrySubscriptionManager
-
Get all the subscriptions.
- getAllSubscriptions() - Method in interface org.wso2.carbon.andes.event.core.subscription.SubscriptionManager
-
Get all the subscriptions.
- getBackendRoles() - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Get array of backend roles excluding admin and wso2.anonymous.role roles
- getBackendRoles() - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Get array of backend roles excluding admin and wso2.anonymous.role roles
- getChildren() - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- getClientID() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- getClientID() - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- getConfigurationContextService() - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getCreatedTime() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getDeliveryManger(OMElement) - Method in interface org.wso2.carbon.andes.event.core.delivery.DeliveryManagerFactory
-
creates and returns the delivery manager from the omElement config.
- getDeliveryManger(OMElement) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManagerFactory
-
creates and returns the delivery manager from the omElement config.
- getDialect() - Method in class org.wso2.carbon.andes.event.core.subscription.EventFilter
-
- getEventBroker(OMElement) - Method in interface org.wso2.carbon.andes.event.core.EventBrokerFactory
-
returns the event broker from the configuration element
- getEventBroker(OMElement) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBrokerFactory
-
returns the event broker from the configuration element
- getEventDispatcher() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getEventDispatcherName() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getEventFilter() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getEventSinkURL() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getExpires() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getHostName() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- getHostName() - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- getId() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getInitialContextProperties(String, String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Return initial context property object for given username and password
- getInitialContextProperties(String, String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
Return initial context property object for given username and password
- getInstance() - Static method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getJMSSubscriptions(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Gets the JMS subscriptions for a given topic
- getJMSSubscriptions(String) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Gets the JMS subscriptions for a given topic
- getLeafNode() - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- getMessage() - Method in class org.wso2.carbon.andes.event.core.Message
-
- getMode() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getNodeName() - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- getObject(OMElement) - Static method in class org.wso2.carbon.andes.event.core.internal.util.JavaUtil
-
returns an object with the type of attibute class.
- getOwner() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getPaginatedTopicTree(String, int, int) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Get the paginated topic tree.
- getPaginatedTopicTree(String, int, int) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Get the paginated topic tree.
- getPort() - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- getProperties() - Method in class org.wso2.carbon.andes.event.core.Message
-
- getProperties() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getProperty(String) - Method in class org.wso2.carbon.andes.event.core.Message
-
- getQpidPort() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- getQpidServerDetails() - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getRealmService() - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getRegistryService() - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getResourcePath(String, String) - Static method in class org.wso2.carbon.andes.event.core.internal.util.JavaUtil
-
- getRoleName() - Method in class org.wso2.carbon.andes.event.core.TopicRolePermission
-
- getSubscription(String) - Method in interface org.wso2.carbon.andes.event.core.EventBroker
-
Get subscription from subscription ID
- getSubscription(String) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Get subscription from subscription ID
- getSubscription(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.RegistrySubscriptionManager
-
Gets the subscription
- getSubscription(Resource) - Static method in class org.wso2.carbon.andes.event.core.internal.util.JavaUtil
-
creates the subscription object from the subscription resource
- getSubscription(String) - Method in interface org.wso2.carbon.andes.event.core.subscription.SubscriptionManager
-
Gets the subscription
- getSubscriptionManager(OMElement) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.RegistrySubscriptionManagerFactory
-
Return subscription manager object from given config
- getSubscriptionManager(OMElement) - Method in interface org.wso2.carbon.andes.event.core.subscription.SubscriptionManagerFactory
-
Return subscription manager object from given config
- getSubscriptionMode(String) - Static method in class org.wso2.carbon.andes.event.core.internal.util.JavaUtil
-
- getSubscriptions(String, boolean) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Gets subscriptions for a topic
- getSubscriptions(String, boolean) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Gets subscriptions for a topic
- getTCPConnectionURL(String, String) - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
Return amqp connection url
- getTenantDomain() - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getTenantDomain() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getTenantId() - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerHolder
-
- getTenantId() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getTopicConnection(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Initialize and return topic connection
- getTopicConnectionFactory(InitialContext) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Return topic connection factory for given initial context properties
- getTopicConnectionFactory(InitialContext) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
Return topic connection factory for given initial context properties
- getTopicManagerService() - Method in interface org.wso2.carbon.andes.event.core.EventBroker
-
Gets the topic manager
- getTopicManagerService() - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Gets the topic manager
- getTopicManagerService(OMElement) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.RegistryTopicManagerServiceFactory
-
Return topic manager service from given configuration
- getTopicManagerService(OMElement) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerServiceFactory
-
Return topic manager service from given configuration
- getTopicName(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Return formatted topic name for given topic
- getTopicName(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
Return formatted topic name for given topic
- getTopicName() - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- getTopicName() - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- getTopicRolePermission(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Gets the permissions for topic
- getTopicRolePermission(String) - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Gets the permissions for topic
- getTopicStoragePath() - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.RegistrySubscriptionManager
-
Gets the topic storage path
- getTopicStoragePath() - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Gets the topic storage path
- getTopicStoragePath() - Method in interface org.wso2.carbon.andes.event.core.subscription.SubscriptionManager
-
Gets the topic storage path
- getTopicTree() - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
Gets the topic tree.
- getTopicTree() - Method in interface org.wso2.carbon.andes.event.core.TopicManagerService
-
Gets the topic tree.
- getType() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- getValue(OMElement, String) - Static method in class org.wso2.carbon.andes.event.core.internal.util.JavaUtil
-
- getValue() - Method in class org.wso2.carbon.andes.event.core.subscription.EventFilter
-
- getVirtualHostName() - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- getVirtualHostName() - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- sendNotification(Message, Subscription) - Method in class org.wso2.carbon.andes.event.core.internal.notify.CarbonNotificationManager
-
Notification message send to given subscription
- sendNotification(Message, Subscription) - Method in interface org.wso2.carbon.andes.event.core.NotificationManager
-
Notification message send to given subscription
- setAccessKey(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- setAccessKey(String) - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- setAllowedToPublish(boolean) - Method in class org.wso2.carbon.andes.event.core.TopicRolePermission
-
- setAllowedToSubscribe(boolean) - Method in class org.wso2.carbon.andes.event.core.TopicRolePermission
-
- setChildren(TopicNode[]) - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- setClientID(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- setClientID(String) - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- setConfigurationContextService(ConfigurationContextService) - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerBuilderDS
-
- setCreatedTime(Date) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setDeactivated(boolean) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Setter method of deactivated flag
- setDeliveryManager(DeliveryManager) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Sets the delivery manager
- setDialect(String) - Method in class org.wso2.carbon.andes.event.core.subscription.EventFilter
-
- setEventBroker(EventBroker) - Method in class org.wso2.carbon.andes.event.core.internal.builder.EventAxis2ConfigurationContextObserver
-
Event broker setter method
- setEventDispatcher(EventDispatcher) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setEventDispatcherName(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setEventFilter(EventFilter) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setEventSinkURL(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setExecutor(ExecutorService) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Sets the executor service
- setExpires(Calendar) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setHostName(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- setHostName(String) - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- setId(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setLeafNode(boolean) - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- setMessage(String) - Method in class org.wso2.carbon.andes.event.core.Message
-
- setMode(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setNodeName(String) - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- setNotificationManager(NotificationManager) - Method in interface org.wso2.carbon.andes.event.core.delivery.DeliveryManager
-
Notification manager is used to send the notifications
- setNotificationManager(NotificationManager) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
Notification manager is used to send the notifications
- setOwner(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setPort(String) - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- setProperties(Map<String, String>) - Method in class org.wso2.carbon.andes.event.core.Message
-
- setProperties(Map<String, String>) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setQpidPort(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- setRealmService(RealmService) - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerBuilderDS
-
- setRegistryService(RegistryService) - Method in class org.wso2.carbon.andes.event.core.internal.ds.EventBrokerBuilderDS
-
- setRoleName(String) - Method in class org.wso2.carbon.andes.event.core.TopicRolePermission
-
- setSubscriptionManager(SubscriptionManager) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Sets new subscription manager
- setTenantDomain(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setTenantId(int) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setTopicManagerService(TopicManagerService) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Sets new topic manager
- setTopicName(String) - Method in class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- setTopicName(String) - Method in class org.wso2.carbon.andes.event.core.TopicNode
-
- setTopicStoragePath(String) - Method in class org.wso2.carbon.andes.event.core.internal.subscription.registry.TopicManagerServiceImpl
-
The topic storage path
- setType(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- setValue(String) - Method in class org.wso2.carbon.andes.event.core.subscription.EventFilter
-
- setVirtualHostName(String) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.QpidJMSDeliveryManager
-
- setVirtualHostName(String) - Method in class org.wso2.carbon.andes.event.core.qpid.QpidServerDetails
-
- startEventBroker() - Method in class org.wso2.carbon.andes.event.core.internal.builder.EventBrokerHandler
-
Start event broker
- stopEventBroker() - Method in class org.wso2.carbon.andes.event.core.internal.builder.EventBrokerHandler
-
Stop event broker
- subscribe(Subscription) - Method in interface org.wso2.carbon.andes.event.core.delivery.DeliveryManager
-
subscribe with the subscription details.
- subscribe(Subscription) - Method in interface org.wso2.carbon.andes.event.core.EventBroker
-
Subscribe using the given subscription details.
- subscribe(Subscription) - Method in class org.wso2.carbon.andes.event.core.internal.CarbonEventBroker
-
Subscribe using the given subscription details.
- subscribe(Subscription) - Method in class org.wso2.carbon.andes.event.core.internal.delivery.jms.JMSDeliveryManager
-
subscribe with the subscription details.
- Subscription - Class in org.wso2.carbon.andes.event.core.subscription
-
Keeps all the subscription related data.
- Subscription() - Constructor for class org.wso2.carbon.andes.event.core.subscription.Subscription
-
- SubscriptionManager - Interface in org.wso2.carbon.andes.event.core.subscription
-
Interface to mange the subscriptions with a persistence storage.
- SubscriptionManagerFactory - Interface in org.wso2.carbon.andes.event.core.subscription
-
Implementation of this interface used to create and get subscription manager object from given config