com.liferay.portal.notifications
Class ChannelImpl

java.lang.Object
  com.liferay.portal.kernel.notifications.BaseChannelImpl
      com.liferay.portal.notifications.ChannelImpl

All Implemented Interfaces:

Channel

public class ChannelImpl
extends BaseChannelImpl

Constructor Summary

ChannelImpl()

ChannelImpl(long companyId, long usedId)

Method Summary

Channel	clone(long companyId, long userId)
void	confirmDelivery(Collection<String> notificationEventUuids)
void	confirmDelivery(Collection<String> notificationEventUuids, boolean archive)
void	confirmDelivery(String notificationEventUuid)
void	confirmDelivery(String notificationEventUuid, boolean archive)
void	deleteUserNotificiationEvent(String notificationEventUuid)
void	deleteUserNotificiationEvents(Collection<String> notificationEventUuids)
protected void	doCleanUp()
protected List<NotificationEvent>	doGetNotificationEvents(boolean flush)
protected void	doInit()
void	flush()
void	flush(long timestamp)
List<NotificationEvent>	getNotificationEvents(boolean flush)
void	init()
protected boolean	isRemoveNotificationEvent(NotificationEvent notificationEvent, long currentTime)
void	removeTransientNotificationEvents(Collection<NotificationEvent> notificationEvents)
void	removeTransientNotificationEventsByUuid(Collection<String> notificationEventUuids)
void	sendNotificationEvent(NotificationEvent notificationEvent)
void	sendNotificationEvents(Collection<NotificationEvent> notificationEvents)
void	storeNotificationEvent(NotificationEvent notificationEvent, long currentTime)

Methods inherited from class com.liferay.portal.kernel.notifications.BaseChannelImpl

cleanUp, close, getCompanyId, getNotificationEvents, getUserId, hasNotificationEvents, notifyChannelListeners, registerChannelListener, setCleanUpInterval, unregisterChannelListener

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelImpl

public ChannelImpl()

ChannelImpl

public ChannelImpl(long companyId,
                   long usedId)

Method Detail

clone

public Channel clone(long companyId,
                     long userId)

confirmDelivery

public void confirmDelivery(Collection<String> notificationEventUuids)
                     throws ChannelException

Throws:

ChannelException

confirmDelivery

public void confirmDelivery(Collection<String> notificationEventUuids,
                            boolean archive)
                     throws ChannelException

Throws:

ChannelException

confirmDelivery

public void confirmDelivery(String notificationEventUuid)
                     throws ChannelException

Throws:

ChannelException

confirmDelivery

public void confirmDelivery(String notificationEventUuid,
                            boolean archive)
                     throws ChannelException

Throws:

ChannelException

deleteUserNotificiationEvent

public void deleteUserNotificiationEvent(String notificationEventUuid)
                                  throws ChannelException

Throws:

ChannelException

deleteUserNotificiationEvents

public void deleteUserNotificiationEvents(Collection<String> notificationEventUuids)
                                   throws ChannelException

Throws:

ChannelException

flush

public void flush()

flush

public void flush(long timestamp)

getNotificationEvents

public List<NotificationEvent> getNotificationEvents(boolean flush)
                                              throws ChannelException

Throws:

ChannelException

init

public void init()
          throws ChannelException

Throws:

ChannelException

removeTransientNotificationEvents

public void removeTransientNotificationEvents(Collection<NotificationEvent> notificationEvents)

removeTransientNotificationEventsByUuid

public void removeTransientNotificationEventsByUuid(Collection<String> notificationEventUuids)

sendNotificationEvent

public void sendNotificationEvent(NotificationEvent notificationEvent)
                           throws ChannelException

Throws:

ChannelException

sendNotificationEvents

public void sendNotificationEvents(Collection<NotificationEvent> notificationEvents)
                            throws ChannelException

Throws:

ChannelException

storeNotificationEvent

public void storeNotificationEvent(NotificationEvent notificationEvent,
                                   long currentTime)

doCleanUp

protected void doCleanUp()
                  throws Exception

Specified by:

doCleanUp in class BaseChannelImpl

Throws:

Exception

doGetNotificationEvents

protected List<NotificationEvent> doGetNotificationEvents(boolean flush)
                                                   throws Exception

Throws:

Exception

doInit

protected void doInit()
               throws SystemException

Throws:

SystemException

isRemoveNotificationEvent

protected boolean isRemoveNotificationEvent(NotificationEvent notificationEvent,
                                            long currentTime)