com.liferay.portal.notifications

Class ChannelHubImpl

Object

com.liferay.portal.notifications.ChannelHubImpl

All Implemented Interfaces:

com.liferay.portal.kernel.notifications.ChannelHub

public class ChannelHubImpl
extends Object
implements com.liferay.portal.kernel.notifications.ChannelHub

Author:

Edward Han, Brian Wing Shun Chan, Shuyang Zhou

Constructor Summary

Constructors

Constructor and Description
ChannelHubImpl(long companyId)

Method Summary

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)
com.liferay.portal.kernel.notifications.Channel	createChannel(long userId)
void	deleteUserNotificiationEvent(long userId, String notificationEventUuid)
void	deleteUserNotificiationEvents(long userId, Collection<String> notificationEventUuids)
void	destroy()
com.liferay.portal.kernel.notifications.Channel	destroyChannel(long userId)
com.liferay.portal.kernel.notifications.Channel	fetchChannel(long userId)
com.liferay.portal.kernel.notifications.Channel	fetchChannel(long userId, boolean createIfAbsent)
List<com.liferay.portal.kernel.notifications.NotificationEvent>	fetchNotificationEvents(long userId)
List<com.liferay.portal.kernel.notifications.NotificationEvent>	fetchNotificationEvents(long userId, boolean flush)
void	flush()
void	flush(long userId)
void	flush(long userId, long timestamp)
com.liferay.portal.kernel.notifications.Channel	getChannel(long userId)
com.liferay.portal.kernel.notifications.Channel	getChannel(long userId, boolean createIfAbsent)
long	getCompanyId()
List<com.liferay.portal.kernel.notifications.NotificationEvent>	getNotificationEvents(long userId)
List<com.liferay.portal.kernel.notifications.NotificationEvent>	getNotificationEvents(long userId, boolean flush)
Collection<Long>	getUserIds()
void	registerChannelListener(long userId, com.liferay.portal.kernel.notifications.ChannelListener channelListener)
void	removeTransientNotificationEvents(long userId, Collection<com.liferay.portal.kernel.notifications.NotificationEvent> notificationEvents)
void	removeTransientNotificationEventsByUuid(long userId, Collection<String> notificationEventUuids)
void	sendNotificationEvent(long userId, com.liferay.portal.kernel.notifications.NotificationEvent notificationEvent)
void	sendNotificationEvents(long userId, Collection<com.liferay.portal.kernel.notifications.NotificationEvent> notificationEvents)
void	storeNotificationEvent(long userId, com.liferay.portal.kernel.notifications.NotificationEvent notificationEvent)
void	unregisterChannelListener(long userId, com.liferay.portal.kernel.notifications.ChannelListener channelListener)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChannelHubImpl

public ChannelHubImpl(long companyId)

Method Detail

cleanUp

public void cleanUp()
             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

cleanUp in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

cleanUp

public void cleanUp(long userId)
             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

cleanUp in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

confirmDelivery

public void confirmDelivery(long userId,
                            Collection<String> notificationEventUuids)
                     throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

confirmDelivery in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

confirmDelivery

public void confirmDelivery(long userId,
                            Collection<String> notificationEventUuids,
                            boolean archive)
                     throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

confirmDelivery in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

confirmDelivery

public void confirmDelivery(long userId,
                            String notificationEventUuid)
                     throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

confirmDelivery in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

confirmDelivery

public void confirmDelivery(long userId,
                            String notificationEventUuid,
                            boolean archive)
                     throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

confirmDelivery in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

createChannel

public com.liferay.portal.kernel.notifications.Channel createChannel(long userId)
                                                              throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

createChannel in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

deleteUserNotificiationEvent

public void deleteUserNotificiationEvent(long userId,
                                         String notificationEventUuid)
                                  throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

deleteUserNotificiationEvent in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

deleteUserNotificiationEvents

public void deleteUserNotificiationEvents(long userId,
                                          Collection<String> notificationEventUuids)
                                   throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

deleteUserNotificiationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

destroy

public void destroy()
             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

destroy in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

destroyChannel

public com.liferay.portal.kernel.notifications.Channel destroyChannel(long userId)
                                                               throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

destroyChannel in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

fetchChannel

public com.liferay.portal.kernel.notifications.Channel fetchChannel(long userId)
                                                             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

fetchChannel in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

fetchChannel

public com.liferay.portal.kernel.notifications.Channel fetchChannel(long userId,
                                                                    boolean createIfAbsent)
                                                             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

fetchChannel in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

fetchNotificationEvents

public List<com.liferay.portal.kernel.notifications.NotificationEvent> fetchNotificationEvents(long userId)
                                                                                        throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

fetchNotificationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

fetchNotificationEvents

public List<com.liferay.portal.kernel.notifications.NotificationEvent> fetchNotificationEvents(long userId,
                                                                                               boolean flush)
                                                                                        throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

fetchNotificationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

flush

public void flush()
           throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

flush in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

flush

public void flush(long userId)
           throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

flush in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

flush

public void flush(long userId,
                  long timestamp)
           throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

flush in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

getChannel

public com.liferay.portal.kernel.notifications.Channel getChannel(long userId)
                                                           throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

getChannel in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

getChannel

public com.liferay.portal.kernel.notifications.Channel getChannel(long userId,
                                                                  boolean createIfAbsent)
                                                           throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

getChannel in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

getCompanyId

public long getCompanyId()

getNotificationEvents

public List<com.liferay.portal.kernel.notifications.NotificationEvent> getNotificationEvents(long userId)
                                                                                      throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

getNotificationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

getNotificationEvents

public List<com.liferay.portal.kernel.notifications.NotificationEvent> getNotificationEvents(long userId,
                                                                                             boolean flush)
                                                                                      throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

getNotificationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

getUserIds

public Collection<Long> getUserIds()

Specified by:

getUserIds in interface com.liferay.portal.kernel.notifications.ChannelHub

registerChannelListener

public void registerChannelListener(long userId,
                                    com.liferay.portal.kernel.notifications.ChannelListener channelListener)
                             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

registerChannelListener in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

removeTransientNotificationEvents

public void removeTransientNotificationEvents(long userId,
                                              Collection<com.liferay.portal.kernel.notifications.NotificationEvent> notificationEvents)
                                       throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

removeTransientNotificationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

removeTransientNotificationEventsByUuid

public void removeTransientNotificationEventsByUuid(long userId,
                                                    Collection<String> notificationEventUuids)
                                             throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

removeTransientNotificationEventsByUuid in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

sendNotificationEvent

public void sendNotificationEvent(long userId,
                                  com.liferay.portal.kernel.notifications.NotificationEvent notificationEvent)
                           throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

sendNotificationEvent in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

sendNotificationEvents

public void sendNotificationEvents(long userId,
                                   Collection<com.liferay.portal.kernel.notifications.NotificationEvent> notificationEvents)
                            throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

sendNotificationEvents in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

storeNotificationEvent

public void storeNotificationEvent(long userId,
                                   com.liferay.portal.kernel.notifications.NotificationEvent notificationEvent)
                            throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

storeNotificationEvent in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException

unregisterChannelListener

public void unregisterChannelListener(long userId,
                                      com.liferay.portal.kernel.notifications.ChannelListener channelListener)
                               throws com.liferay.portal.kernel.notifications.ChannelException

Specified by:

unregisterChannelListener in interface com.liferay.portal.kernel.notifications.ChannelHub

Throws:

com.liferay.portal.kernel.notifications.ChannelException