@Service public class ActivityController extends AbstractEventController
ActivityController handles the processing and routing of activities.| Modifier and Type | Field and Description |
|---|---|
protected static String |
ACTIVITY_TOPIC_COMETD |
protected static String |
ACTIVITY_TOPIC_COMETD_BROADCAST |
protected static String |
ACTIVITY_TOPIC_COMETD_NEW |
EVENT_TOPIC_CANCEL| Constructor and Description |
|---|
ActivityController(PersistentStore persistentStore,
org.osgi.framework.BundleContext bundleContext,
org.osgi.service.event.EventAdmin eventAdmin) |
| Modifier and Type | Method and Description |
|---|---|
void |
deletePersistentActivity(org.cometd.bayeux.server.ServerSession serverSession,
org.cometd.bayeux.server.ServerMessage serverMessage) |
List<Map<String,Object>> |
getActivitiesForUser(String userId) |
String |
getControllerRootTopic()
Obtains the root topic of the controller that should be used when registering the eventhandler.
|
void |
getPersistedActivities(org.cometd.bayeux.server.ServerSession remote,
org.cometd.bayeux.Message message) |
void |
handleEvent(org.osgi.service.event.Event event)
Implementation of
EventHandler.handleEvent(Event) that receives
notifications published on the ActivityEvent.EVENT_TOPIC topic from the OSGi eventing
framework and forwards them to their intended recipients. |
adminCancelDownload, deregisterUserSession, getSessionById, getSessionBySessionId, getSessionByUserId, getUserId, queuePersistedMessages, registerUserSessionprotected static final String ACTIVITY_TOPIC_COMETD
protected static final String ACTIVITY_TOPIC_COMETD_BROADCAST
protected static final String ACTIVITY_TOPIC_COMETD_NEW
public ActivityController(PersistentStore persistentStore, org.osgi.framework.BundleContext bundleContext, org.osgi.service.event.EventAdmin eventAdmin)
public void handleEvent(org.osgi.service.event.Event event)
throws IllegalArgumentException
EventHandler.handleEvent(Event) that receives
notifications published on the ActivityEvent.EVENT_TOPIC topic from the OSGi eventing
framework and forwards them to their intended recipients.IllegalArgumentException - when any of the following required properties are either
missing from the Event or contain empty values:
@Listener(value="/ddf/activities")
public void getPersistedActivities(org.cometd.bayeux.server.ServerSession remote,
org.cometd.bayeux.Message message)
@Listener(value="/service/action")
public void deletePersistentActivity(org.cometd.bayeux.server.ServerSession serverSession,
org.cometd.bayeux.server.ServerMessage serverMessage)
public String getControllerRootTopic()
AbstractEventControllergetControllerRootTopic in class AbstractEventControllerThis work is licensed under a Creative Commons Attribution 4.0 International License.