1 files changed, 25 insertions, 1 deletions
diff --git a/org.eclipse.mylyn.tasks.activity.core/src/org/eclipse/mylyn/internal/tasks/activity/core/ActivityManager.java b/org.eclipse.mylyn.tasks.activity.core/src/org/eclipse/mylyn/internal/tasks/activity/core/ActivityManager.java
index fc3664a1e..ecb278670 100644
--- a/org.eclipse.mylyn.tasks.activity.core/src/org/eclipse/mylyn/internal/tasks/activity/core/ActivityManager.java
+++ b/org.eclipse.mylyn.tasks.activity.core/src/org/eclipse/mylyn/internal/tasks/activity/core/ActivityManager.java
@@ -11,17 +11,41 @@
 
 package org.eclipse.mylyn.internal.tasks.activity.core;
 
+import java.util.Collection;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.eclipse.mylyn.tasks.activity.core.ActivityEvent;
 import org.eclipse.mylyn.tasks.activity.core.ActivityScope;
 import org.eclipse.mylyn.tasks.activity.core.IActivityManager;
 import org.eclipse.mylyn.tasks.activity.core.IActivityStream;
+import org.eclipse.mylyn.tasks.activity.core.spi.IActivitySession;
 
 /**
  * @author Steffen Pingel
  */
-public class ActivityManager implements IActivityManager {
+public class ActivityManager implements IActivityManager, IActivitySession {
+
+	private final Map<String, ActivityEvent> events;
+
+	public ActivityManager() {
+		this.events = new ConcurrentHashMap<String, ActivityEvent>();
+	}
+
+	public Collection<ActivityEvent> getEvents(ActivityScope scope) {
+		return events.values();
+	}
 
 	public IActivityStream getStream(ActivityScope scope) {
 		return new ActivityStream(this, scope);
 	}
 
+	public IActivityManager getManger() {
+		return this;
+	}
+
+	public void fireActivityEvent(ActivityEvent event) {
+		events.put(event.getHandle(), event);
+	}
+
 }