public interface ChannelHub
| Modifier and Type | Method and Description |
|---|---|
void |
cleanUp() |
void |
cleanUp(long userId) |
void |
confirmDelivery(long userId,
Collection<String> notificationEventUuids) |
void |
confirmDelivery(long userId,
Collection<String> notificationEventUuids,
boolean archive) |
void |
confirmDelivery(long userId,
String notificationEventUuid) |
void |
confirmDelivery(long userId,
String notificationEventUuid,
boolean archive) |
Channel |
createChannel(long userId) |
void |
deleteUserNotificiationEvent(long userId,
String notificationEventUuid) |
void |
deleteUserNotificiationEvents(long userId,
Collection<String> notificationEventUuids) |
void |
destroy() |
Channel |
destroyChannel(long userId) |
Channel |
fetchChannel(long userId) |
Channel |
fetchChannel(long userId,
boolean createIfAbsent) |
List<NotificationEvent> |
fetchNotificationEvents(long userId) |
List<NotificationEvent> |
fetchNotificationEvents(long userId,
boolean flush) |
void |
flush() |
void |
flush(long userId) |
void |
flush(long userId,
long timestamp) |
Channel |
getChannel(long userId) |
Channel |
getChannel(long userId,
boolean createIfAbsent) |
List<NotificationEvent> |
getNotificationEvents(long userId) |
List<NotificationEvent> |
getNotificationEvents(long userId,
boolean flush) |
Collection<Long> |
getUserIds() |
void |
registerChannelListener(long userId,
ChannelListener channelListener) |
void |
removeTransientNotificationEvents(long userId,
Collection<NotificationEvent> notificationEvents) |
void |
removeTransientNotificationEventsByUuid(long userId,
Collection<String> notificationEventUuids) |
void |
sendNotificationEvent(long userId,
NotificationEvent notificationEvent) |
void |
sendNotificationEvents(long userId,
Collection<NotificationEvent> notificationEvents) |
void |
storeNotificationEvent(long userId,
NotificationEvent notificationEvent) |
void |
unregisterChannelListener(long userId,
ChannelListener channelListener) |
void cleanUp()
throws ChannelException
ChannelExceptionvoid cleanUp(long userId)
throws ChannelException
ChannelExceptionvoid confirmDelivery(long userId,
Collection<String> notificationEventUuids)
throws ChannelException
ChannelExceptionvoid confirmDelivery(long userId,
Collection<String> notificationEventUuids,
boolean archive)
throws ChannelException
ChannelExceptionvoid confirmDelivery(long userId,
String notificationEventUuid)
throws ChannelException
ChannelExceptionvoid confirmDelivery(long userId,
String notificationEventUuid,
boolean archive)
throws ChannelException
ChannelExceptionChannel createChannel(long userId) throws ChannelException
ChannelExceptionvoid deleteUserNotificiationEvent(long userId,
String notificationEventUuid)
throws ChannelException
ChannelExceptionvoid deleteUserNotificiationEvents(long userId,
Collection<String> notificationEventUuids)
throws ChannelException
ChannelExceptionvoid destroy()
throws ChannelException
ChannelExceptionChannel destroyChannel(long userId) throws ChannelException
ChannelExceptionChannel fetchChannel(long userId) throws ChannelException
ChannelExceptionChannel fetchChannel(long userId, boolean createIfAbsent) throws ChannelException
ChannelExceptionList<NotificationEvent> fetchNotificationEvents(long userId) throws ChannelException
ChannelExceptionList<NotificationEvent> fetchNotificationEvents(long userId, boolean flush) throws ChannelException
ChannelExceptionvoid flush()
throws ChannelException
ChannelExceptionvoid flush(long userId)
throws ChannelException
ChannelExceptionvoid flush(long userId,
long timestamp)
throws ChannelException
ChannelExceptionChannel getChannel(long userId) throws ChannelException
ChannelExceptionChannel getChannel(long userId, boolean createIfAbsent) throws ChannelException
ChannelExceptionList<NotificationEvent> getNotificationEvents(long userId) throws ChannelException
ChannelExceptionList<NotificationEvent> getNotificationEvents(long userId, boolean flush) throws ChannelException
ChannelExceptionCollection<Long> getUserIds()
void registerChannelListener(long userId,
ChannelListener channelListener)
throws ChannelException
ChannelExceptionvoid removeTransientNotificationEvents(long userId,
Collection<NotificationEvent> notificationEvents)
throws ChannelException
ChannelExceptionvoid removeTransientNotificationEventsByUuid(long userId,
Collection<String> notificationEventUuids)
throws ChannelException
ChannelExceptionvoid sendNotificationEvent(long userId,
NotificationEvent notificationEvent)
throws ChannelException
ChannelExceptionvoid sendNotificationEvents(long userId,
Collection<NotificationEvent> notificationEvents)
throws ChannelException
ChannelExceptionvoid storeNotificationEvent(long userId,
NotificationEvent notificationEvent)
throws ChannelException
ChannelExceptionvoid unregisterChannelListener(long userId,
ChannelListener channelListener)
throws ChannelException
ChannelException