配置JNDI为TIBCO EMS在Tomcat中

Question

我已经写了一些代码，用于创建来自TIBCO EMS

TopicConnectionFactory factory = new TibjmsTopicConnectionFactory(serverUrl); 
TopicConnection connection = factory.createTopicConnection(username, password); 
/* if clientID is specified we must set it right here */ 
if (clientID != null) { 
    connection.setClientID(clientID); 
} 

主题连接其中的serverUrl，用户名，密码和的clientId从配置文件读取。我被告知应该使用JNDI来做这件事（我对此非常不了解），我需要做什么？

更新

从各类搜索我想过把这个在context.xml中可能是适当的

<Resource auth="Container" brokerName="not-tibco-952v" brokerURL="tcp://not-tibco-952v:10905" 
      description="JMS Connection Factory" factory="com.tibco.tibjms.naming.TibjmsObjectFactory" 
      name="jms/ProvisioningMessageConnectionFactory" type="com.tibco.tibjms.naming.TibjmsConnectionFactoryAttributes" 
      factoryClass="com.tibco.tibjms.TibjmsConnectionFactory" jndiName="TopicConnectionFactory" serverUrl="not-tibco-952v:10905" 
      username="tibco" password="tibco"/> 

但

final Object obj = initialContext.lookup("java:comp/env/jms/ProvisioningMessageConnectionFactory"); 

带回一个空的结果

Answer 1

在没有任何bette的情况下[R知识，我创建了自己的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");