# builder = require 'xmlbuilder'

ActiveMQ Configure

module.exports = ->
  activemq = @config.ryba.activemq ?= {}

Environment

  activemq.version ?= '5.14.3'
  activemq.server ?= {}
  activemq.conf_dir ?= '/etc/activemq/conf'
  activemq.log_dir ?= '/var/log/activemq'
  activemq.data_dir ?= '/var/activemq/data'

Identities

  # Group
  activemq.group ?= {}
  activemq.group = name: activemq.group if typeof activemq.group is 'string'
  activemq.group.name ?= 'activemq'
  activemq.group.system ?= true
  # User
  activemq.user ?= {}
  activemq.user = name: activemq.user if typeof activemq.user is 'string'
  activemq.user.name ?= 'activemq'
  activemq.user.home ?= "/var/#{activemq.user.name}"
  activemq.user.system ?= true
  activemq.user.comment ?= 'ActiveMQ User'
  activemq.user.groups ?= 'hadoop'
  activemq.user.gid ?= activemq.group.name

Ports

  activemq.server.port ?= {}
  activemq.server.port.jms ?= '61616'
  activemq.server.port.ui ?= '8161'
  activemq.server.container_name ?= 'activemq_server'
  activemq.server.ports ?= {}
  activemq.server.ports.openwire ?= {}
  activemq.server.ports.openwire.protocol ?= 'tcp'
  activemq.server.ports.openwire.port ?= 61616
  activemq.server.ports.amqp ?= {}
  activemq.server.ports.amqp.protocol ?= 'amqp'
  activemq.server.ports.amqp.port ?= 5672
  activemq.server.ports.stomp ?= {}
  activemq.server.ports.stomp.protocol ?= 'stomp'
  activemq.server.ports.stomp.port ?= 61613
  activemq.server.ports.stomp ?= {}
  activemq.server.ports.stomp.protocol ?= 'stomp'
  activemq.server.ports.stomp.port ?= 61613
  activemq.server.ports.mqtt ?= {}
  activemq.server.ports.mqtt.protocol ?= 'mqtt'
  activemq.server.ports.mqtt.port ?= 1883
  activemq.server.ports.ws ?= {}
  activemq.server.ports.ws.protocol ?= 'ws'
  activemq.server.ports.ws.port ?= 61614

Configuration

  activemq.conf ?= {}
  activemq.conf['beans'] = {
    '@xmlns': "http://www.springframework.org/schema/beans"
    '@xmlns:xsi': "http://www.w3.org/2001/XMLSchema-instance"
    '@xsi:schemaLocation': "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd",
    bean: [
      {
       '@class': "org.springframework.beans.factory.config.PropertyPlaceholderConfigurer",
       'property': {'@name': 'locations', value: 'file:${activemq.conf}/credentials.properties'}
      },
      {
        '@id': 'logQuery'
        '@class': "io.fabric8.insight.log.log4j.Log4jLogQuery",
        '@lazy-init': "false",
        '@scope': "singleton",
        '@init-method': "start",
        '@destroy-method': "stop"
      }
    ],
    broker: {
      '@xmlns': "http://activemq.apache.org/schema/core",
      '@brokerName': "#{@config.host}",
      '@dataDirectory': "${activemq.data}",
      '@networkConnectorStartAsync': true,
      destinationPolicy: {
        policyMap: {
          policyEntries: [
            policyEntry : { '@topic': '>',  pendingMessageLimitStrategy: {constantPendingMessageLimitStrategy: {'@limit':1000}} }
          ]
        }
      },
      managementContext : { managementContext : {'@createConnector': "false"} },
      persistenceAdapter : { kahaDB : {'@directory': "${activemq.data}/kahadb"} },
      systemUsage: {
        systemUsage: {
          memoryUsage : { memoryUsage : {'@percentOfJvmHeap': 70} },
          storeUsage  : { storeUsage  : {'@limit': "10 gb"} },
          tempUsage   : { tempUsage   : {'@limit': "1 gb"} }
        }
      },
      shutdownHooks: {
        bean: [
          { '@xmlns': 'http://www.springframework.org/schema/beans',  '@class': 'org.apache.activemq.hooks.SpringContextHook' }
        ]
      },
      transportConnectors: { transportConnector: [] },
      networkConnectors: { networkConnector: [] }
    },
    import: {'@resource': "jetty.xml"}
  }
  # Ports enabled
  for k,v of activemq.server.ports
    activemq.conf['beans'].broker.transportConnectors.transportConnector.push {
      '@name': "#{k}", '@uri': "#{v['protocol']}"+'://0.0.0.0:'+"#{v['port']}"+'?maximumConnections=1000&wireFormat.maxFrameSize=104857600'
    }
  # Network of Brokers
  localhost = @config.host
  for host in @contexts('ryba/activemq/server').filter((c)->c.config.host != localhost).map((c)->c.config.host)
    activemq.conf['beans'].broker.networkConnectors.networkConnector.push {
      '@name': "#{host}",
      '@uri': "static:(tcp://#{host}:61616)",
      '@duplex': 'true',
      '@decreaseNetworkConsumerPriority': false,
      '@networkTTL': 2,
      '@dynamicOnly': true
    }
  # Connection string
  hosts = @contexts('ryba/activemq/server').map((c)->"tcp://#{c.config.host}:#{activemq.server.ports['openwire'].port}")
  if hosts.length > 1
    jms_url = "failover:(" + hosts.join(',') + ")?randomize=false&maxReconnectAttempts=10&initialReconnectDelay=100&priorityBackup=true"
  else
    jms_url = "#{hosts[0]}"
  # Integrate Oozie with ActiveMQ
  @config.ryba.oozie ?= {}
  @config.ryba.oozie.jms_url ?= jms_url
  # Integrate HCatalog with ActiveMQ
  @config.ryba.hive ?= {}
  @config.ryba.hive.hcatalog ?= {}
  @config.ryba.hive.hcatalog.jms_url ?= jms_url