org.apache.sling.event.impl.jobs
Class JobConsumerManager

java.lang.Object
  extended by org.apache.sling.event.impl.jobs.JobConsumerManager

@Service(value=JobConsumerManager.class)
@Reference(referenceInterface=JobConsumer.class,
           cardinality=OPTIONAL_MULTIPLE,
           policy=DYNAMIC)
@Property(name="org.apache.sling.installer.configuration.persist",
          boolValue=false,
          propertyPrivate=true)
public class JobConsumerManager
extends Object

This component manages/keeps track of all job consumer services.


Constructor Summary
JobConsumerManager()
           
 
Method Summary
protected  void activate(org.osgi.framework.BundleContext bc, Map<String,Object> props)
           
protected  void bindJobConsumer(org.osgi.framework.ServiceReference serviceReference)
          Bind a new consumer
protected  void deactivate()
           
 JobConsumer getConsumer(String topic)
          Get the consumer for the topic.
 String getTopics()
          Return the topics information of this instance.
protected  void modified(org.osgi.framework.BundleContext bc, Map<String,Object> props)
           
 boolean supportsBridgedEvents()
          Does this instance supports bridged events?
protected  void unbindJobConsumer(org.osgi.framework.ServiceReference serviceReference)
          Unbind a consumer
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JobConsumerManager

public JobConsumerManager()
Method Detail

activate

@Activate
protected void activate(org.osgi.framework.BundleContext bc,
                                 Map<String,Object> props)

modified

@Modified
protected void modified(org.osgi.framework.BundleContext bc,
                                 Map<String,Object> props)

deactivate

@Deactivate
protected void deactivate()

getConsumer

public JobConsumer getConsumer(String topic)
Get the consumer for the topic.

Parameters:
topic - The job topic
Returns:
A consumer or null

getTopics

public String getTopics()
Return the topics information of this instance.


supportsBridgedEvents

public boolean supportsBridgedEvents()
Does this instance supports bridged events?


bindJobConsumer

protected void bindJobConsumer(org.osgi.framework.ServiceReference serviceReference)
Bind a new consumer

Parameters:
serviceReference - The service reference to the consumer.

unbindJobConsumer

protected void unbindJobConsumer(org.osgi.framework.ServiceReference serviceReference)
Unbind a consumer

Parameters:
serviceReference - The service reference to the consumer.


Copyright © 2007-2013 The Apache Software Foundation. All Rights Reserved.