@Deprecated public interface EventBroker
EventDispatcher
with
the given name. In a server restart again caller has to register the
EventDispatcher
.Modifier and Type | Method and Description |
---|---|
List<Subscription> |
getAllSubscriptions(String filter)
Deprecated.
Get all subscriptions
|
Subscription |
getSubscription(String id)
Deprecated.
Get subscription from subscription ID
|
TopicManager |
getTopicManager()
Deprecated.
Gets the topic manager
|
void |
initializeTenant()
Deprecated.
This method is called when a tenant initialize.
|
void |
publish(Message message,
String topicName)
Deprecated.
Publish an event to the given topic asynchronously.
|
void |
publish(Message message,
String topicName,
int deliveryMode)
Deprecated.
Publish an event to the given topic asynchronously.
|
void |
publishRobust(Message message,
String topicName)
Deprecated.
Publish an event to the given topic synchronously.
|
void |
publishRobust(Message message,
String topicName,
int deliveryMode)
Deprecated.
Publish an event to the given topic synchronously.
|
void |
registerEventDispatcher(String eventDispatcherName,
EventDispatcher eventDispatcher)
Deprecated.
Register an event dispatcher in the case of using subscriptions with eventBrokerName
|
void |
renewSubscription(Subscription subscription)
Deprecated.
Renews a subscription.
|
String |
subscribe(Subscription subscription)
Deprecated.
Subscribe using the given subscription details.
|
void |
unsubscribe(String id)
Deprecated.
Unsubscribes a subscription
|
String subscribe(Subscription subscription) throws EventBrokerException
subscription
- the subscriptionEventBrokerException
void unsubscribe(String id) throws EventBrokerException
id
- subscription IDEventBrokerException
Subscription getSubscription(String id) throws EventBrokerException
id
- subscription IDEventBrokerException
void renewSubscription(Subscription subscription) throws EventBrokerException
subscription
- the subscription to renewEventBrokerException
List<Subscription> getAllSubscriptions(String filter) throws EventBrokerException
filter
- filter value. use * for allEventBrokerException
void publish(Message message, String topicName) throws EventBrokerException
message
- - message to publish. this contains the OMElement of the message and any
properties.topicName
- topic nameEventBrokerException
void publish(Message message, String topicName, int deliveryMode) throws EventBrokerException
message
- - message to publish. this contains the OMElement of the message and any
properties.topicName
- topic namedeliveryMode
- - persist or notEventBrokerException
void publishRobust(Message message, String topicName) throws EventBrokerException
message
- message to publish. this contains the OMElement of the message and any
properties.topicName
- topic nameEventBrokerException
void publishRobust(Message message, String topicName, int deliveryMode) throws EventBrokerException
message
- - message to publish. this contains the OMElement of the message and any
properties.topicName
- topic namedeliveryMode
- - persist or notEventBrokerException
void registerEventDispatcher(String eventDispatcherName, EventDispatcher eventDispatcher)
eventDispatcherName
- event dispatcher nameeventDispatcher
- event dispatcherTopicManager getTopicManager() throws EventBrokerException
EventBrokerException
void initializeTenant() throws EventBrokerException, org.wso2.carbon.user.api.UserStoreException
EventBrokerException
org.wso2.carbon.user.api.UserStoreException
Copyright © 2022 WSO2. All rights reserved.