@Deprecated public class InMemoryDeliveryManager extends Object implements DeliveryManager
Constructor and Description |
---|
InMemoryDeliveryManager(ExecutorService executor,
String topicStoragePath)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
cleanUp()
Deprecated.
|
void |
initializeTenant()
Deprecated.
|
void |
publish(Message message,
String topicName,
int deliveryMode)
Deprecated.
publish an omElement to a topic
|
void |
renewSubscription(Subscription subscription)
Deprecated.
|
void |
setMatchingManager(MatchingManager matchingManager)
Deprecated.
|
void |
setNotificationManager(NotificationManager notificationManager)
Deprecated.
Notification manager is used to send the notifications
|
void |
subscribe(Subscription subscription)
Deprecated.
subscribe with the subscription details.
|
void |
unSubscribe(String id)
Deprecated.
|
public InMemoryDeliveryManager(ExecutorService executor, String topicStoragePath)
public void subscribe(Subscription subscription) throws EventBrokerException
DeliveryManager
subscribe
in interface DeliveryManager
EventBrokerException
public void setNotificationManager(NotificationManager notificationManager)
DeliveryManager
setNotificationManager
in interface DeliveryManager
public void publish(Message message, String topicName, int deliveryMode) throws EventBrokerException
DeliveryManager
publish
in interface DeliveryManager
EventBrokerException
public void setMatchingManager(MatchingManager matchingManager)
public void unSubscribe(String id) throws EventBrokerException
unSubscribe
in interface DeliveryManager
EventBrokerException
public void cleanUp()
cleanUp
in interface DeliveryManager
public void renewSubscription(Subscription subscription) throws EventBrokerException
renewSubscription
in interface DeliveryManager
EventBrokerException
public void initializeTenant() throws EventBrokerException
initializeTenant
in interface DeliveryManager
EventBrokerException
Copyright © 2022 WSO2. All rights reserved.