Skip to content

Instantly share code, notes, and snippets.

@maxschremser

maxschremser/JndiConfiguration.java

Created May 4, 2016 21:10
Show Gist options
  • Save maxschremser/7cd2d2ae4dbd0dce47fc1f9c6b135b0e to your computer and use it in GitHub Desktop.
Save maxschremser/7cd2d2ae4dbd0dce47fc1f9c6b135b0e to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. maxschremser created this gist May 4, 2016.
    89 changes: 89 additions & 0 deletions JndiConfiguration.java
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,89 @@
    package com.schremser.spring.jms.core;

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.PropertySource;
    import org.springframework.jms.connection.TransactionAwareConnectionFactoryProxy;
    import org.springframework.jndi.JndiObjectFactoryBean;
    import org.springframework.jndi.JndiTemplate;

    import javax.jms.ConnectionFactory;
    import javax.naming.Context;
    import java.util.Properties;

    @Configuration
    @PropertySource("classpath:default.properties")
    public class JndiConfiguration {
    private final static Logger log = LoggerFactory.getLogger(JndiConfiguration.class);

    // JMS Connection properties
    @Value("${" + Context.INITIAL_CONTEXT_FACTORY + "}") private String initialContextFactory;
    @Value("${" + Context.PROVIDER_URL + "}") private String providerUrl;
    @Value("${" + Context.SECURITY_PRINCIPAL + "}") private String securityPrincipal;
    @Value("${" + Context.SECURITY_CREDENTIALS + "}") private String securityCredentials;

    // JMS ConnectionFactory
    @Value("${jms.connection.factory}") private String connectionFactory;

    // Queues
    @Value("${jms.queue.import}") private String importQueue;
    @Value("${jms.queue.export}") private String exportQueue;

    @Bean
    public JndiTemplate jndiTemplate() {
    log.info(toString());
    Properties environment = new Properties();
    environment.setProperty(Context.INITIAL_CONTEXT_FACTORY, initialContextFactory);
    environment.setProperty(Context.PROVIDER_URL, providerUrl);
    environment.setProperty(Context.SECURITY_PRINCIPAL, securityPrincipal);
    environment.setProperty(Context.SECURITY_CREDENTIALS, securityCredentials);

    JndiTemplate jndiTemplate = new JndiTemplate();
    jndiTemplate.setEnvironment(environment);
    return jndiTemplate;
    }

    @Bean
    public JndiObjectFactoryBean connectionFactory() {
    JndiObjectFactoryBean factoryBean = new JndiObjectFactoryBean();
    factoryBean.setJndiTemplate(jndiTemplate());
    factoryBean.setJndiName(connectionFactory);
    return factoryBean;
    }

    @Bean
    public JndiObjectFactoryBean importQueue() {
    JndiObjectFactoryBean factoryBean = new JndiObjectFactoryBean();
    factoryBean.setJndiTemplate(jndiTemplate());
    factoryBean.setJndiName(importQueue);
    return factoryBean;
    }

    @Bean
    public JndiObjectFactoryBean exportQueue() {
    JndiObjectFactoryBean factoryBean = new JndiObjectFactoryBean();
    factoryBean.setJndiTemplate(jndiTemplate());
    factoryBean.setJndiName(exportQueue);
    return factoryBean;
    }

    @Bean
    public TransactionAwareConnectionFactoryProxy connectionFactoryProxy() {
    return new TransactionAwareConnectionFactoryProxy((ConnectionFactory) connectionFactory().getObject());
    }

    @Override
    public String toString() {
    return "JndiConfiguration{jms.queue.import=" + importQueue +
    ", jms.queue.export=" + exportQueue +
    ", java.naming.factory.initial=" + initialContextFactory +
    ", java.naming.provider.url=" + providerUrl +
    ", java.naming.security.principal=" + securityPrincipal +
    ", jms.connection.factory=" + connectionFactory +
    "}";
    }

    }