@Deprecated public class CarbonEventBroker extends Object implements EventBroker
Constructor and Description |
---|
CarbonEventBroker()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanUp()
Deprecated.
Cleans up the delivery broker
|
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 |
init()
Deprecated.
Initializes the carbon event broker.
|
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.
|
void |
setDeliveryManager(DeliveryManager deliveryManager)
Deprecated.
Sets the delivery manager
|
void |
setExecutor(ExecutorService executor)
Deprecated.
Sets the executor service
|
void |
setSubscriptionManager(SubscriptionManager subscriptionManager)
Deprecated.
Sets new subscription manager
|
void |
setTopicManager(TopicManager topicManager)
Deprecated.
Sets new topic manager
|
String |
subscribe(Subscription subscription)
Deprecated.
Subscribe using the given subscription details.
|
void |
unsubscribe(String id)
Deprecated.
Unsubscribes a subscription
|
public void init() throws EventBrokerConfigurationException
public void initializeTenant() throws EventBrokerException, org.wso2.carbon.user.api.UserStoreException
initializeTenant
in interface EventBroker
EventBrokerException
org.wso2.carbon.user.api.UserStoreException
public String subscribe(Subscription subscription) throws EventBrokerException
subscribe
in interface EventBroker
subscription
- the subscriptionEventBrokerException
public void unsubscribe(String id) throws EventBrokerException
unsubscribe
in interface EventBroker
id
- subscription IDEventBrokerException
public Subscription getSubscription(String id) throws EventBrokerException
getSubscription
in interface EventBroker
id
- subscription IDEventBrokerException
public void renewSubscription(Subscription subscription) throws EventBrokerException
renewSubscription
in interface EventBroker
subscription
- the subscription to renewEventBrokerException
public List<Subscription> getAllSubscriptions(String filter) throws EventBrokerException
getAllSubscriptions
in interface EventBroker
filter
- filter value. use * for allEventBrokerException
public void publish(Message message, String topicName) throws EventBrokerException
publish
in interface EventBroker
message
- - message to publish. this contains the OMElement of the message and any
properties.topicName
- topic nameEventBrokerException
public void publish(Message message, String topicName, int deliveryMode) throws EventBrokerException
publish
in interface EventBroker
message
- - message to publish. this contains the OMElement of the message and any
properties.topicName
- topic namedeliveryMode
- - persist or notEventBrokerException
public void publishRobust(Message message, String topicName) throws EventBrokerException
publishRobust
in interface EventBroker
message
- message to publish. this contains the OMElement of the message and any
properties.topicName
- topic nameEventBrokerException
public void publishRobust(Message message, String topicName, int deliveryMode) throws EventBrokerException
publishRobust
in interface EventBroker
message
- - message to publish. this contains the OMElement of the message and any
properties.topicName
- topic namedeliveryMode
- - persist or notEventBrokerException
public void registerEventDispatcher(String eventDispatcherName, EventDispatcher eventDispatcher)
registerEventDispatcher
in interface EventBroker
eventDispatcherName
- event dispatcher nameeventDispatcher
- event dispatcherpublic void setSubscriptionManager(SubscriptionManager subscriptionManager)
subscriptionManager
- new subscription managerpublic TopicManager getTopicManager()
getTopicManager
in interface EventBroker
public void setTopicManager(TopicManager topicManager)
topicManager
- new topic managerpublic void setDeliveryManager(DeliveryManager deliveryManager)
deliveryManager
- new delivery managerpublic void setExecutor(ExecutorService executor)
executor
- new executor servicepublic void cleanUp() throws EventBrokerException
EventBrokerException
Copyright © 2024 WSO2. All rights reserved.