public class DefaultSubscriptionManager extends java.lang.Object implements SubscriptionManager
SubscriptionManager
interface that does
nothing.Constructor and Description |
---|
DefaultSubscriptionManager() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Clears all subscriptions.
|
FailedResubscribeHandler |
getFailedResubscribeHandler()
Gets the failed resubscribe handler.
|
void |
resubscribe(Client client)
Resubscribes using the provided client.
|
void |
setFailedResubscribeHandler(FailedResubscribeHandler failureHandler)
Sets the failed resubscribe handler.
|
void |
subscribe(MessageHandler messageHandler,
Message message)
Subscribes to a message handler with a message.
|
void |
unsubscribe(CommandId subId)
Unsubscribes a subscription by subId.
|
public void subscribe(MessageHandler messageHandler, Message message)
subscribe
in interface SubscriptionManager
messageHandler
- The message handler to subscribe.message
- The message to subscribe to.public void unsubscribe(CommandId subId)
unsubscribe
in interface SubscriptionManager
subId
- The subscription ID to unsubscribe.public void clear()
clear
in interface SubscriptionManager
public void resubscribe(Client client) throws AMPSException
resubscribe
in interface SubscriptionManager
client
- The client to resubscribe.AMPSException
- If an error occurs during resubscription.public FailedResubscribeHandler getFailedResubscribeHandler()
getFailedResubscribeHandler
in interface SubscriptionManager
public void setFailedResubscribeHandler(FailedResubscribeHandler failureHandler)
setFailedResubscribeHandler
in interface SubscriptionManager
failureHandler
- The failed resubscribe handler to set.