public class QueueServiceManager extends DestinationServiceManager
| Modifier and Type | Field and Description |
|---|---|
protected QueueDestinationsResource |
destination |
protected PushStore |
pushStore |
protected List<QueueDeployment> |
queues |
consumerServerLocator, consumerSessionFactory, defaultSettings, jmsOptions, linkStrategy, locator, producerPoolSize, producerTimeToLive, pushStoreFile, registry, sessionFactory, started, timeoutTask| Constructor and Description |
|---|
QueueServiceManager(ConnectionFactoryOptions jmsOptions) |
| Modifier and Type | Method and Description |
|---|---|
void |
deploy(QueueDeployment queueDeployment) |
QueueDestinationsResource |
getDestination() |
PushStore |
getPushStore() |
List<QueueDeployment> |
getQueues() |
void |
setDestination(QueueDestinationsResource destination) |
void |
setPushStore(PushStore pushStore) |
void |
setQueues(List<QueueDeployment> queues) |
void |
start() |
void |
stop() |
getConsumerServerLocator, getConsumerSessionFactory, getDefaultSettings, getJmsOptions, getLinkStrategy, getProducerPoolSize, getProducerTimeToLive, getPushStoreFile, getRegistry, getServerLocator, getSessionFactory, getTimeoutTask, initDefaults, setConsumerServerLocator, setConsumerSessionFactory, setDefaultSettings, setLinkStrategy, setProducerPoolSize, setProducerTimeToLive, setPushStoreFile, setRegistry, setServerLocator, setSessionFactory, setTimeoutTaskprotected PushStore pushStore
protected List<QueueDeployment> queues
protected QueueDestinationsResource destination
public QueueServiceManager(ConnectionFactoryOptions jmsOptions)
public List<QueueDeployment> getQueues()
public void setQueues(List<QueueDeployment> queues)
public PushStore getPushStore()
public void setPushStore(PushStore pushStore)
public QueueDestinationsResource getDestination()
public void setDestination(QueueDestinationsResource destination)
public void start()
throws Exception
start in class DestinationServiceManagerExceptionpublic void deploy(QueueDeployment queueDeployment) throws Exception
Exceptionpublic void stop()
stop in class DestinationServiceManagerCopyright © 2024 The Apache Software Foundation. All rights reserved.