public class MonitoringDistributionQueueProvider extends Object implements DistributionQueueProvider
DistributionQueueProvider
that supports monitoring via JMX.Constructor and Description |
---|
MonitoringDistributionQueueProvider(DistributionQueueProvider wrapped,
org.osgi.framework.BundleContext context) |
Modifier and Type | Method and Description |
---|---|
void |
disableQueueProcessing()
disables queue processing
|
void |
enableQueueProcessing(DistributionQueueProcessor queueProcessor,
String... queueNames)
enables queue processing
|
DistributionQueue |
getQueue(String queueName)
provide an
DistributionQueueType.ORDERED queue with the given name |
DistributionQueue |
getQueue(String queueName,
DistributionQueueType type)
provde a queue of the given type with the given name
|
public MonitoringDistributionQueueProvider(DistributionQueueProvider wrapped, org.osgi.framework.BundleContext context)
public DistributionQueue getQueue(String queueName) throws DistributionException
DistributionQueueProvider
DistributionQueueType.ORDERED
queue with the given namegetQueue
in interface DistributionQueueProvider
queueName
- the name of the queue to retrieveDistributionQueue
DistributionException
public DistributionQueue getQueue(String queueName, DistributionQueueType type)
DistributionQueueProvider
getQueue
in interface DistributionQueueProvider
queueName
- the name of the queuetype
- the type of the queueDistributionQueue
public void enableQueueProcessing(DistributionQueueProcessor queueProcessor, String... queueNames) throws DistributionException
DistributionQueueProvider
enableQueueProcessing
in interface DistributionQueueProvider
queueProcessor
- the queue processor to be usedDistributionException
public void disableQueueProcessing() throws DistributionException
DistributionQueueProvider
disableQueueProcessing
in interface DistributionQueueProvider
DistributionException
Copyright © 2007–2018 The Apache Software Foundation. All rights reserved.