org.nuxeo.ecm.activity

Class ActivityStreamServiceImpl

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.ecm.activity.ActivityStreamServiceImpl

All Implemented Interfaces:

ActivityStreamService, Adaptable, Component, Extensible, TimestampedService

public class ActivityStreamServiceImpl
extends DefaultComponent
implements ActivityStreamService

Default implementation of ActivityStreamService.

Since:

5.5

Author:

Thomas Roger

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVITIES_PROVIDER
static String	ACTIVITY_LINK_BUILDERS_EP
static String	ACTIVITY_STREAM_FILTER_EP
static String	ACTIVITY_STREAMS_EP
static String	ACTIVITY_UPGRADERS_EP
static String	ACTIVITY_VERBS_EP
protected ActivityLinkBuilderRegistry	activityLinkBuilderRegistry
protected Map<String,ActivityStreamFilter>	activityStreamFilters
protected ActivityStreamRegistry	activityStreamRegistry
protected ActivityUpgraderRegistry	activityUpgraderRegistry
protected ActivityVerbRegistry	activityVerbRegistry
protected RepositoryInitializationHandler	initializationHandler
protected ThreadLocal<javax.persistence.EntityManager>	localEntityManager
protected PersistenceProvider	persistenceProvider

Fields inherited from class org.nuxeo.runtime.model.DefaultComponent

lastModified, name

Fields inherited from interface org.nuxeo.ecm.activity.ActivityStreamService

ALL_ACTIVITIES

Constructor Summary

Constructors

Constructor and Description
ActivityStreamServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	activate(ComponentContext context) Activates the component.
protected void	activatePersistenceProvider()
Activity	addActivity(Activity activity) Add and store a new Activity.
protected void	addActivity(javax.persistence.EntityManager em, Activity activity)
ActivityReply	addActivityReply(Serializable activityId, ActivityReply activityReply) Add an ActivityReply to the Activity referenced by the activityId.
protected String	computeNewReplyId(Activity activity)
void	deactivate(ComponentContext context) Deactivates the component.
protected void	deactivatePersistenceProvider()
ActivitiesList	getActivities(Collection<Serializable> activityIds)
protected ActivitiesList	getActivities(javax.persistence.EntityManager em, Collection<Serializable> activityIds)
protected Activity	getActivity(javax.persistence.EntityManager em, Serializable activityId)
Activity	getActivity(Serializable activityId)
ActivityLinkBuilder	getActivityLinkBuilder(String name) Returns the ActivityLinkBuilder with the given name.
ActivityStream	getActivityStream(String name) Returns the ActivityStream with the given name, null if it does not exist.
javax.persistence.EntityManager	getEntityManager()
PersistenceProvider	getOrCreatePersistenceProvider()
protected ActivitiesList	query(ActivityStreamFilter filter, Map<String,Serializable> parameters, long offset, long limit)
protected ActivitiesList	query(javax.persistence.EntityManager em, ActivityStreamFilter filter, Map<String,Serializable> parameters, long offset, long limit)
ActivitiesList	query(String filterId, Map<String,Serializable> parameters) Returns the list of activities filtered by the given parameters using the ActivityStreamFilter referenced by filterId.
ActivitiesList	query(String filterId, Map<String,Serializable> parameters, long offset, long limit) Returns the list of activities filtered by the given parameters using the ActivityStreamFilter referenced by filterId.
protected ActivitiesList	queryAll(javax.persistence.EntityManager em, long offset, long limit)
protected ActivitiesList	queryAll(long offset, long limit)
void	registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor)
void	removeActivities(Collection<Activity> activities) Remove the given activities.
protected void	removeActivities(javax.persistence.EntityManager em, Collection<Activity> activities)
protected ActivityReply	removeActivityReply(javax.persistence.EntityManager em, Serializable activityId, String activityReplyId)
ActivityReply	removeActivityReply(Serializable activityId, String activityReplyId) Remove an ActivityReply from the Activity referenced by the activityId.
ActivityMessage	toActivityMessage(Activity activity, Locale locale) Computes an ActivityMessage from the given activity and locale.
ActivityMessage	toActivityMessage(Activity activity, Locale locale, String activityLinkBuilderName) Computes an ActivityMessage from the given activity, locale and use .
ActivityReplyMessage	toActivityReplyMessage(ActivityReply activityReply, Locale locale) Computes an ActivityReplyMessage from the given activityReply and locale.
ActivityReplyMessage	toActivityReplyMessage(ActivityReply activityReply, Locale locale, String activityLinkBuilderName) Computes an ActivityReplyMessage from the given activityReply and locale.
void	unregisterContribution(Object contribution, String extensionPoint, ComponentInstance contributor)
protected void	updateActivity(Activity activity)
void	upgradeActivities()
protected void	upgradeActivities(javax.persistence.EntityManager em, ActivityUpgrader upgrader)

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

getAdapter, getDescriptor, getDescriptors, getLastModified, getRegistry, register, registerExtension, setLastModified, setModifiedNow, setName, start, stop, unregister, unregisterExtension

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.runtime.model.Component

applicationStarted, getApplicationStartedOrder

Field Detail

ACTIVITIES_PROVIDER

public static final String ACTIVITIES_PROVIDER

See Also:

Constant Field Values

ACTIVITY_STREAM_FILTER_EP

public static final String ACTIVITY_STREAM_FILTER_EP

See Also:

Constant Field Values

ACTIVITY_STREAMS_EP

public static final String ACTIVITY_STREAMS_EP

See Also:

Constant Field Values

ACTIVITY_VERBS_EP

public static final String ACTIVITY_VERBS_EP

See Also:

Constant Field Values

ACTIVITY_LINK_BUILDERS_EP

public static final String ACTIVITY_LINK_BUILDERS_EP

See Also:

Constant Field Values

ACTIVITY_UPGRADERS_EP

public static final String ACTIVITY_UPGRADERS_EP

See Also:

Constant Field Values

localEntityManager

protected final ThreadLocal<javax.persistence.EntityManager> localEntityManager

activityStreamFilters

protected final Map<String,ActivityStreamFilter> activityStreamFilters

activityStreamRegistry

protected ActivityStreamRegistry activityStreamRegistry

activityVerbRegistry

protected ActivityVerbRegistry activityVerbRegistry

activityLinkBuilderRegistry

protected ActivityLinkBuilderRegistry activityLinkBuilderRegistry

activityUpgraderRegistry

protected ActivityUpgraderRegistry activityUpgraderRegistry

persistenceProvider

protected PersistenceProvider persistenceProvider

initializationHandler

protected RepositoryInitializationHandler initializationHandler

Constructor Detail

ActivityStreamServiceImpl

public ActivityStreamServiceImpl()

Method Detail

upgradeActivities

public void upgradeActivities()

upgradeActivities

protected void upgradeActivities(javax.persistence.EntityManager em,
                                 ActivityUpgrader upgrader)

query

public ActivitiesList query(String filterId,
                            Map<String,Serializable> parameters)

Description copied from interface: ActivityStreamService

Returns the list of activities filtered by the given parameters using the ActivityStreamFilter referenced by filterId.

Specified by:

query in interface ActivityStreamService

Parameters:

filterId - the id of the ActivityStreamFilter to use.

parameters - this query parameters.

query

public ActivitiesList query(String filterId,
                            Map<String,Serializable> parameters,
                            long offset,
                            long limit)

Description copied from interface: ActivityStreamService

Returns the list of activities filtered by the given parameters using the ActivityStreamFilter referenced by filterId.

Specified by:

query in interface ActivityStreamService

Parameters:

filterId - the id of the ActivityStreamFilter to use.

parameters - this query parameters.

offset - the offset (starting at 0) into the list of activities.

limit - the maximum number of activities to retrieve, or 0 for all of them.

query

protected ActivitiesList query(ActivityStreamFilter filter,
                               Map<String,Serializable> parameters,
                               long offset,
                               long limit)

query

protected ActivitiesList query(javax.persistence.EntityManager em,
                               ActivityStreamFilter filter,
                               Map<String,Serializable> parameters,
                               long offset,
                               long limit)

queryAll

protected ActivitiesList queryAll(long offset,
                                  long limit)

queryAll

protected ActivitiesList queryAll(javax.persistence.EntityManager em,
                                  long offset,
                                  long limit)

addActivity

public Activity addActivity(Activity activity)

Description copied from interface: ActivityStreamService

Add and store a new Activity.

Specified by:

addActivity in interface ActivityStreamService

addActivity

protected void addActivity(javax.persistence.EntityManager em,
                           Activity activity)

removeActivities

public void removeActivities(Collection<Activity> activities)

Description copied from interface: ActivityStreamService

Remove the given activities.

Specified by:

removeActivities in interface ActivityStreamService

removeActivities

protected void removeActivities(javax.persistence.EntityManager em,
                                Collection<Activity> activities)

toActivityMessage

public ActivityMessage toActivityMessage(Activity activity,
                                         Locale locale)

Description copied from interface: ActivityStreamService

Computes an ActivityMessage from the given activity and locale.

Specified by:

toActivityMessage in interface ActivityStreamService

toActivityMessage

public ActivityMessage toActivityMessage(Activity activity,
                                         Locale locale,
                                         String activityLinkBuilderName)

Description copied from interface: ActivityStreamService

Computes an ActivityMessage from the given activity, locale and use .

Specified by:

toActivityMessage in interface ActivityStreamService

getActivityLinkBuilder

public ActivityLinkBuilder getActivityLinkBuilder(String name)

Description copied from interface: ActivityStreamService

Returns the ActivityLinkBuilder with the given name.

If name is null, or if the ActivityLinkBuilder does not exist, fallback on the default one if any.

Specified by:

getActivityLinkBuilder in interface ActivityStreamService

toActivityReplyMessage

public ActivityReplyMessage toActivityReplyMessage(ActivityReply activityReply,
                                                   Locale locale)

Description copied from interface: ActivityStreamService

Computes an ActivityReplyMessage from the given activityReply and locale.

Specified by:

toActivityReplyMessage in interface ActivityStreamService

toActivityReplyMessage

public ActivityReplyMessage toActivityReplyMessage(ActivityReply activityReply,
                                                   Locale locale,
                                                   String activityLinkBuilderName)

Description copied from interface: ActivityStreamService

Computes an ActivityReplyMessage from the given activityReply and locale.

Specified by:

toActivityReplyMessage in interface ActivityStreamService

getActivityStream

public ActivityStream getActivityStream(String name)

Description copied from interface: ActivityStreamService

Returns the ActivityStream with the given name, null if it does not exist.

Specified by:

getActivityStream in interface ActivityStreamService

addActivityReply

public ActivityReply addActivityReply(Serializable activityId,
                                      ActivityReply activityReply)

Description copied from interface: ActivityStreamService

Add an ActivityReply to the Activity referenced by the activityId.

Specified by:

addActivityReply in interface ActivityStreamService

Returns:

the updated activityReply

computeNewReplyId

protected String computeNewReplyId(Activity activity)

Since:

5.6

getActivity

public Activity getActivity(Serializable activityId)

Specified by:

getActivity in interface ActivityStreamService

getActivities

public ActivitiesList getActivities(Collection<Serializable> activityIds)

Specified by:

getActivities in interface ActivityStreamService

removeActivityReply

public ActivityReply removeActivityReply(Serializable activityId,
                                         String activityReplyId)

Description copied from interface: ActivityStreamService

Remove an ActivityReply from the Activity referenced by the activityId.

Specified by:

removeActivityReply in interface ActivityStreamService

Returns:

the removed ActivityReply if any, null otherwise

removeActivityReply

protected ActivityReply removeActivityReply(javax.persistence.EntityManager em,
                                            Serializable activityId,
                                            String activityReplyId)

Since:

5.6

getActivity

protected Activity getActivity(javax.persistence.EntityManager em,
                               Serializable activityId)

getActivities

protected ActivitiesList getActivities(javax.persistence.EntityManager em,
                                       Collection<Serializable> activityIds)

updateActivity

protected void updateActivity(Activity activity)

getEntityManager

public javax.persistence.EntityManager getEntityManager()

getOrCreatePersistenceProvider

public PersistenceProvider getOrCreatePersistenceProvider()

activatePersistenceProvider

protected void activatePersistenceProvider()

deactivatePersistenceProvider

protected void deactivatePersistenceProvider()

activate

public void activate(ComponentContext context)

Description copied from interface: Component

Activates the component.

This method is called by the runtime when a component is activated.

Specified by:

activate in interface Component

Overrides:

activate in class DefaultComponent

Parameters:

context - the runtime context

deactivate

public void deactivate(ComponentContext context)

Description copied from interface: Component

Deactivates the component.

This method is called by the runtime when a component is deactivated.

Specified by:

deactivate in interface Component

Overrides:

deactivate in class DefaultComponent

Parameters:

context - the runtime context

registerContribution

public void registerContribution(Object contribution,
                                 String extensionPoint,
                                 ComponentInstance contributor)

Overrides:

registerContribution in class DefaultComponent

unregisterContribution

public void unregisterContribution(Object contribution,
                                   String extensionPoint,
                                   ComponentInstance contributor)

Overrides:

unregisterContribution in class DefaultComponent