2011-02-01 32 views
1

我设置了ActiveMQ,我可以使用“dynamicTopics/MyTopic”创建/连接到主题。这个伟大的工程:Apache ActiveMQ非动态连接主题

Properties env = new Properties(); 
    env.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory"); 
    env.setProperty(Context.PROVIDER_URL,"tcp://myhostname:xxxxx"); 
    javax.naming.Context ctx = new InitialContext(env); 

    InitialContext jndi = new InitialContext(env); 

    // Look up a JMS connection factory 
    TopicConnectionFactory conFactory = (TopicConnectionFactory)jndi.lookup("TopicConnectionFactory"); 

    // Create a JMS connection 
    TopicConnection connection = conFactory.createTopicConnection(username,password); 

    Topic chatTopic = (Topic)jndi.lookup("dynamicTopics/MyTopic"); 

我想连接到一个话题已经不存在动态创建,如果它不存在的话题,我该怎么办呢?

干杯,

皮特

回答

0

什么你实际上做的是刚刚连接到的话题。 ActiveMQ非常好,如果它之前不存在,它会为您创建主题。

因此,要连接到已经存在的主题,只需执行与您已经执行的操作相同的操作。

+0

对不起,如果我不清楚,但我*不*希望ActiveMQ的创建这个话题对我来说如果不存在的话。我怎样才能做到这一点? – Peter 2011-02-01 17:18:49