public class MessageServiceManager extends Object
Modifier and Type | Field and Description |
---|---|
protected String |
configResourcePath |
protected boolean |
configSet |
protected MessageServiceConfiguration |
configuration |
protected QueueServiceManager |
queueManager |
protected BindingRegistry |
registry |
protected ExecutorService |
threadPool |
protected TimeoutTask |
timeoutTask |
protected int |
timeoutTaskInterval |
protected TopicServiceManager |
topicManager |
Constructor and Description |
---|
MessageServiceManager(ConnectionFactoryOptions jmsOptions) |
Modifier and Type | Method and Description |
---|---|
String |
getConfigResourcePath() |
MessageServiceConfiguration |
getConfiguration() |
QueueServiceManager |
getQueueManager() |
BindingRegistry |
getRegistry() |
ExecutorService |
getThreadPool() |
int |
getTimeoutTaskInterval() |
TopicServiceManager |
getTopicManager() |
void |
setConfigResourcePath(String configResourcePath) |
void |
setConfiguration(MessageServiceConfiguration configuration) |
void |
setRegistry(BindingRegistry registry) |
void |
setThreadPool(ExecutorService threadPool) |
void |
setTimeoutTaskInterval(int timeoutTaskInterval) |
void |
start() |
void |
stop() |
protected ExecutorService threadPool
protected QueueServiceManager queueManager
protected TopicServiceManager topicManager
protected TimeoutTask timeoutTask
protected int timeoutTaskInterval
protected MessageServiceConfiguration configuration
protected boolean configSet
protected String configResourcePath
protected BindingRegistry registry
public MessageServiceManager(ConnectionFactoryOptions jmsOptions)
public BindingRegistry getRegistry()
public void setRegistry(BindingRegistry registry)
public int getTimeoutTaskInterval()
public void setTimeoutTaskInterval(int timeoutTaskInterval)
public ExecutorService getThreadPool()
public void setThreadPool(ExecutorService threadPool)
public QueueServiceManager getQueueManager()
public TopicServiceManager getTopicManager()
public MessageServiceConfiguration getConfiguration()
public String getConfigResourcePath()
public void setConfigResourcePath(String configResourcePath)
public void setConfiguration(MessageServiceConfiguration configuration)
public void stop()
Copyright © 2016 The Apache Software Foundation. All rights reserved.