@Service(value=QueueConfigurationManager.class) @Reference(referenceInterface=InternalQueueConfiguration.class, policy=DYNAMIC, cardinality=OPTIONAL_MULTIPLE, bind="bindConfig", unbind="unbindConfig", updated="updateConfig") public class QueueConfigurationManager extends Object
Modifier and Type | Class and Description |
---|---|
static class |
QueueConfigurationManager.QueueInfo |
Constructor and Description |
---|
QueueConfigurationManager() |
Modifier and Type | Method and Description |
---|---|
void |
addListener(ConfigurationChangeListener listener)
Add a config listener.
|
protected void |
bindConfig(InternalQueueConfiguration config)
Add a new queue configuration.
|
InternalQueueConfiguration[] |
getConfigurations()
Return all configurations.
|
InternalQueueConfiguration |
getMainQueueConfiguration()
Get the configuration for the main queue.
|
QueueConfigurationManager.QueueInfo |
getQueueInfo(String topic)
Find the queue configuration for the job.
|
void |
removeListener()
Remove the config listener.
|
protected void |
unbindConfig(InternalQueueConfiguration config)
Remove a queue configuration.
|
protected void |
updateConfig(InternalQueueConfiguration config)
Update a queue configuration.
|
protected void bindConfig(InternalQueueConfiguration config)
config
- A new queue configuration.protected void unbindConfig(InternalQueueConfiguration config)
config
- The queue configuraiton.protected void updateConfig(InternalQueueConfiguration config)
config
- The queue configuraiton.public InternalQueueConfiguration[] getConfigurations()
public InternalQueueConfiguration getMainQueueConfiguration()
public QueueConfigurationManager.QueueInfo getQueueInfo(String topic)
public void addListener(ConfigurationChangeListener listener)
listener
- public void removeListener()
Copyright © 2007–2014 The Apache Software Foundation. All rights reserved.