【发布时间】:2011-02-02 20:02:29
【问题描述】:
我已经设置了 ActiveMQ,我可以使用“dynamicTopics/MyTopic”创建/连接到一个主题。这很好用:
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");
我想连接一个已经存在的主题而不动态创建该主题,如果它不存在,我该怎么做?
干杯,
皮特
【问题讨论】: