@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, registerUserSession
protected 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()
AbstractEventController
getControllerRootTopic
in class AbstractEventController
This work is licensed under a Creative Commons Attribution 4.0 International License.