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, removeTopic
public TopicsContextImpl(ThreadFactory threadFactory)
ThreadFactory
for creating new cached thread pool executor for publishingprotected Topic createTopic(TopicKey key)
TopicsContext
createTopic
in class TopicsContext
protected 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.