在没有任何更好的知识的情况下，我创建了自己的 ObjectFactory
public class ProvisioningConnectionsFactory implements ObjectFactory {
public Object getObjectInstance(Object obj,
Name namex, Context nameCtx, Hashtable environment)
throws NamingException {
// Acquire an instance of our specified bean class
ProvisioningConnection conns = new ProvisioningConnection();
// Customize the bean properties from our attributes
Reference ref = (Reference) obj;
Enumeration addrs = ref.getAll();
while (addrs.hasMoreElements()) {
RefAddr addr = (RefAddr) addrs.nextElement();
String name = addr.getType();
String value = (String) addr.getContent();
if (name.equals("serverUrl")) {
conns.setServerUrl(value);
} else if (name.equals("username")) {
conns.setUsername(value);
} else if (name.equals("password")) {
conns.setPassword(value);
} else if (name.equals("durableTopicSubscriberName")) {
conns.setDurableTopicSubscriberName(value);
} else if (name.equals("topicName")) {
conns.setTopicName(value);
}
}
// Return the customized instance
return conns;
}
}
这意味着我可以将以下内容添加到我的 context.xml 中：
<Resource name="jms/ProvisioningMessageConnection" auth="Container"
type="com.foo.mytrialsprovisioning.ProvisioningConnection"
factory="com.foo.mytrialsprovisioning.ProvisioningConnectionsFactory"
serverUrl = "tcp://not-tibco-952v:10905"
username = "tibco"
password = "tibco"
durableTopicSubscriberName = "PROVISIONING_SUBSCRIBER"
topicName = "FOOBAR"
/>
和 ProvisioningConnection 的一个实例：
public class ProvisioningConnection {
private static final Log LOG = LogFactory.getLog(new CurrentClassGetter().getClassName());
private static final String MESSAGE_SELECTOR = "client_ID='%s'";
private String serverUrl;
private String username;
private String password;
private String durableTopicSubscriberName;
private String projectIdentifier;
private String topicName;
public void setServerUrl(String serverUrl) {
this.serverUrl = serverUrl;
}
public void setUsername(String username) {
this.username = username;
}
public void setPassword(String password) {
this.password = password;
}
public void setDurableTopicSubscriberName(String durableTopicSubscriberName) {
this.durableTopicSubscriberName = durableTopicSubscriberName;
}
public void setProjectIdentifier(String projectIdentifier) {
this.projectIdentifier = projectIdentifier;
}
public void setTopicName(String topicName) {
this.topicName = topicName;
}
public TopicConnection getTopicConnection()
throws JMSException, NamingException {
LOG.info("Provisioning against server: " + serverUrl);
TopicConnectionFactory factory = new TibjmsTopicConnectionFactory(serverUrl);
TopicConnection connection = factory.createTopicConnection(username, password);
/* if clientID is specified we must set it right here */
if (projectIdentifier != null) {
connection.setClientID(projectIdentifier);
}
return connection;
}
public TopicSubscriber getTopicSubscriber(Session session)
throws JMSException {
LOG.info("Provisioning subscription on topic: " + topicName);
// Use createTopic() to enable subscriptions to dynamic topics.
Topic topic = session.createTopic(topicName);
return session.createDurableSubscriber(topic, durableTopicSubscriberName, (
Tools.isNullOrEmptyString(projectIdentifier) ?
"" :
String.format(MESSAGE_SELECTOR, projectIdentifier)
), true);
}
}
可以使用以下方法创建：
Context envCtx = (Context) initCtx.lookup("java:comp/env");
return (ProvisioningConnection)envCtx.lookup("jms/ProvisioningMessageConnection");