public PooledConnectionFactory jmsFactory()

in src/main/java/org/apache/fineract/cn/command/config/CommandModuleConfiguration.java [69:83]

15 lines of code
2 McCabe index (conditional complexity)


  public PooledConnectionFactory jmsFactory() {
    final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
    final ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
    activeMQConnectionFactory.setBrokerURL(
        this.environment.getProperty(
            CommandConstants.ACTIVEMQ_BROKER_URL_PROP,
            CommandConstants.ACTIVEMQ_BROKER_URL_DEFAULT));
    if (!StringUtils.isEmpty(this.environment.getProperty(CommandConstants.ACTIVEMQ_USERNAME))) {
      Assert.hasLength(this.environment.getProperty(CommandConstants.ACTIVEMQ_PASSWORD),"Amqp password is not supplied");
      activeMQConnectionFactory.setUserName(this.environment.getProperty(CommandConstants.ACTIVEMQ_USERNAME));
      activeMQConnectionFactory.setPassword(this.environment.getProperty(CommandConstants.ACTIVEMQ_PASSWORD));
    }
    pooledConnectionFactory.setConnectionFactory(activeMQConnectionFactory);
    return pooledConnectionFactory;
  }