public class ActiveMQInitialContextFactory extends Object implements InitialContextFactory
ConnectionFactory
instances as well as a child context called
destinations which contain all of the current active destinations, in
child context depending on the QoS such as transient or durable and queue or
topic.Modifier and Type | Field and Description |
---|---|
static String |
DISCOVERY_INITIAL_WAIT_TIMEOUT |
static String |
DYNAMIC_QUEUE_CONTEXT |
static String |
DYNAMIC_TOPIC_CONTEXT |
static String |
REFRESH_TIMEOUT |
Constructor and Description |
---|
ActiveMQInitialContextFactory() |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.ConnectionFactory |
createConnectionFactory(String uri,
String name)
Factory method to create a new connection factory from the given environment
|
protected ReadOnlyContext |
createContext(Hashtable environment,
Map<String,Object> data) |
protected javax.jms.Queue |
createQueue(String name)
Factory method to create new Queue instances
|
protected void |
createQueues(Map<String,Object> data,
Hashtable environment) |
protected javax.jms.Topic |
createTopic(String name)
Factory method to create new Topic instances
|
protected void |
createTopics(Map<String,Object> data,
Hashtable environment) |
Context |
getInitialContext(Hashtable environment) |
String |
getQueuePrefix() |
String |
getTopicPrefix() |
void |
setQueuePrefix(String queuePrefix) |
void |
setTopicPrefix(String topicPrefix) |
public static final String REFRESH_TIMEOUT
public static final String DISCOVERY_INITIAL_WAIT_TIMEOUT
public static final String DYNAMIC_QUEUE_CONTEXT
public static final String DYNAMIC_TOPIC_CONTEXT
public Context getInitialContext(Hashtable environment) throws NamingException
getInitialContext
in interface InitialContextFactory
NamingException
public String getTopicPrefix()
public void setTopicPrefix(String topicPrefix)
public String getQueuePrefix()
public void setQueuePrefix(String queuePrefix)
protected ReadOnlyContext createContext(Hashtable environment, Map<String,Object> data)
protected javax.jms.Queue createQueue(String name)
protected javax.jms.Topic createTopic(String name)
Copyright © 2015 The Apache Software Foundation. All rights reserved.