@Service(value={java.lang.Runnable.class,QueueManager.class,org.osgi.service.event.EventHandler.class}) @Properties(value={@Property(name="scheduler.period",longValue=60L),@Property(name="scheduler.concurrent",boolValue=false),@Property(name="event.topics",value="org/apache/sling/event/notification/job/ADDED")}) public class QueueManager extends Object implements Runnable, org.osgi.service.event.EventHandler, ConfigurationChangeListener
Constructor and Description |
---|
QueueManager() |
Modifier and Type | Method and Description |
---|---|
protected void |
activate(Map<String,Object> props)
Activate this component.
|
void |
configurationChanged(boolean active)
This method is called whenever the topology or queue configurations change.
|
protected void |
deactivate()
Deactivate this component.
|
Queue |
getQueue(String name) |
Iterable<Queue> |
getQueues() |
void |
handleEvent(org.osgi.service.event.Event event) |
void |
run()
This method is invoked periodically by the scheduler.
|
@Activate protected void activate(Map<String,Object> props)
props
- Configuration properties@Deactivate protected void deactivate()
public void run()
run
in interface Runnable
Runnable.run()
public Iterable<Queue> getQueues()
JobManager.getQueues()
public void configurationChanged(boolean active)
configurationChanged
in interface ConfigurationChangeListener
caps
- The new topology capabilities or null
if currently unknown.public void handleEvent(org.osgi.service.event.Event event)
handleEvent
in interface org.osgi.service.event.EventHandler
EventHandler.handleEvent(org.osgi.service.event.Event)
Copyright © 2007–2014 The Apache Software Foundation. All rights reserved.