public class TopicsContextImpl extends TopicsContext
TopicsContext that uses ExecutorService with cached thread pool for publishing messages.| Constructor and Description |
|---|
TopicsContextImpl(ThreadFactory threadFactory)
Use given
ThreadFactory for creating new cached thread pool executor for publishing |
| Modifier and Type | Method and Description |
|---|---|
protected Topic |
createTopic(TopicKey key)
Creates topic for given topic key
|
void |
destroy() |
protected ExecutorService |
getPublisherService()
Returns a publisher
ExecutorService that is used for publishing messages |
protected ThreadFactory |
getThreadFactory()
Returns associated
ThreadFactory used to create executors. |
getOrCreateTopic, getTopic, getTopicKeyWithResolvedExpressions, lookup, publish, removeTopicpublic TopicsContextImpl(ThreadFactory threadFactory)
ThreadFactory for creating new cached thread pool executor for publishingprotected Topic createTopic(TopicKey key)
TopicsContextcreateTopic in class TopicsContextprotected ExecutorService getPublisherService()
ExecutorService that is used for publishing messagesprotected ThreadFactory getThreadFactory()
ThreadFactory used to create executors.public void destroy()
Copyright © 2015 JBoss by Red Hat. All Rights Reserved.