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
ChannelException
void cleanUp(long userId) throws ChannelException
ChannelException
void confirmDelivery(long userId, Collection<String> notificationEventUuids) throws ChannelException
ChannelException
void confirmDelivery(long userId, Collection<String> notificationEventUuids, boolean archive) throws ChannelException
ChannelException
void confirmDelivery(long userId, String notificationEventUuid) throws ChannelException
ChannelException
void confirmDelivery(long userId, String notificationEventUuid, boolean archive) throws ChannelException
ChannelException
Channel createChannel(long userId) throws ChannelException
ChannelException
void deleteUserNotificiationEvent(long userId, String notificationEventUuid) throws ChannelException
ChannelException
void deleteUserNotificiationEvents(long userId, Collection<String> notificationEventUuids) throws ChannelException
ChannelException
void destroy() throws ChannelException
ChannelException
Channel destroyChannel(long userId) throws ChannelException
ChannelException
Channel fetchChannel(long userId) throws ChannelException
ChannelException
Channel fetchChannel(long userId, boolean createIfAbsent) throws ChannelException
ChannelException
List<NotificationEvent> fetchNotificationEvents(long userId) throws ChannelException
ChannelException
List<NotificationEvent> fetchNotificationEvents(long userId, boolean flush) throws ChannelException
ChannelException
void flush() throws ChannelException
ChannelException
void flush(long userId) throws ChannelException
ChannelException
void flush(long userId, long timestamp) throws ChannelException
ChannelException
Channel getChannel(long userId) throws ChannelException
ChannelException
Channel getChannel(long userId, boolean createIfAbsent) throws ChannelException
ChannelException
List<NotificationEvent> getNotificationEvents(long userId) throws ChannelException
ChannelException
List<NotificationEvent> getNotificationEvents(long userId, boolean flush) throws ChannelException
ChannelException
Collection<Long> getUserIds()
void registerChannelListener(long userId, ChannelListener channelListener) throws ChannelException
ChannelException
void removeTransientNotificationEvents(long userId, Collection<NotificationEvent> notificationEvents) throws ChannelException
ChannelException
void removeTransientNotificationEventsByUuid(long userId, Collection<String> notificationEventUuids) throws ChannelException
ChannelException
void sendNotificationEvent(long userId, NotificationEvent notificationEvent) throws ChannelException
ChannelException
void sendNotificationEvents(long userId, Collection<NotificationEvent> notificationEvents) throws ChannelException
ChannelException
void storeNotificationEvent(long userId, NotificationEvent notificationEvent) throws ChannelException
ChannelException
void unregisterChannelListener(long userId, ChannelListener channelListener) throws ChannelException
ChannelException