Forge Home

Modules

Resources

PuppetEcosystemPuppet CommunityUpdates

activemq

Configures Apache MQ
Project URLRSS FeedReport issues

8,373 downloads

8,373 latest version

0

Version information

  • 0.0.1 (latest)
released Jun 3rd 2014

Start using this module

  • r10k or Code Manager
  • Bolt
  • Manual installation
  • Direct download

Add this module to your Puppetfile:

mod 'CERNOps-activemq', '0.0.1'
Learn more about managing modules with a Puppetfile

Add this module to your Bolt project:

bolt module add CERNOps-activemq
Learn more about using this module with an existing project

Manually install this module globally with Puppet module tool:

puppet module install CERNOps-activemq --version 0.0.1

Direct download is not typically how you would use a Puppet module to manage your infrastructure, but you may want to download the module in order to inspect the code.

Download
Tags: activemq

Documentation

CERNOps/activemq — version 0.0.1 Jun 3rd 2014

#puppet-activemq

This is a activemq module to install and configure ActiveMQ. The module includes a number of defined types to additinally configure multiple extra elements of an ActiveMQ service.

  1. activemq::auth - Adds authorizationEntry entities to an activemq.xml file.
  2. activemq::network - Adds networkConnector entities to an activemq.xml file.
  3. activemq::policy - Adds policyEntry entities to an activemq.xml file.
  4. activemq::transport - Adds transportConnector entities to an activemq.xml file.
  5. activemq::user - Adds authenticationUser entities to an activemq.xml file.

See each defined type for additional documentation as well activemq::init for generic parameters.

Example

This example is very much based on the configuration of ActiveMQ for the Mcollective messaging application but hopefully ActiveMQ can be configured for other things with this module.

    # Install an activemq instance and configure various options
    # including a java keystore and nofile and nproc limits
    # for the activemq user.
    class{ 'activemq':
       amqmemory  => '2 gb',
       amqstore   => '10 gb',
       amqtemp    => '1 gb',
       max_memory => '36195', 
       dedicatedTaskRunner => false,
       keystore            => true,
       ca                  => '/etc/pki/tls/certs/MyCA-bundle.pem',
       amqrestart          => true,
       amqfilelimit        => '105000',
       amqproclimit        => '10240'

    }

    # Add activemq users
    activemq::user{'activemq':
        password => 'xyx'
        groups   => ['admins','everyone']
    }
    activemq::user{'mcclient':
        password => 'yut',
        groups   => ['mco','everyone']
    }

    activemq::user{'mcollective':
        password => 'yut'
        groups   => ['mco','everyone']
    }
    # Add authorization access for users to queues and topics.
    activemq::auth{'admin_queue':
        type     => 'queue',
        path     => '>',
        write    => ['admins'],
        read     => ['admins'],
        admin    => ['admins']
    }
    activemq::auth{'admin_topic':
        type     => 'topic',
        path     => '>',
        write    => ['admins'],
        read     => ['admins'],
        admin    => ['admins']
    }
    activemq::auth{'everyone_advise':
        type     => 'topic',
        path     => 'ActiveMQ.Advisory.>',
        write    => ['everyone'],
        read     => ['everyone'],
        admin    => ['everyone']
    }

    activemq::auth{'mco_agent':
        type     => 'topic',
        path     => '*.*.agent',
        write    => ['mco'],
        read     => ['mco'],
        admin    => ['mco']
    }
    activemq::auth{'mco_nodes':
        type     => 'queue',
        path     => '*.nodes',
        write    => ['mco'],
        read     => ['mco'],
        admin    => ['mco']
    }
    activemq::auth{'mco_reply':
        type     => 'queue',
        path     => '*.reply.>',
        write    => ['mco'],
        read     => ['mco'],
        admin    => ['mco']
    }


    # Add some transport connecters.
    activemq::transport{'stomp_nio_ssl':
        name     => 'stomp+nio+ssl',
        uri      => 'stomp+nio+ssl://0.0.0.0:61614'
    }
    # For interconnect between brokers.
    activemq::transport{'openwire':
        name     => 'openwire',
        uri      => 'tcp://0.0.0.0:61616'
    }

    # Some default policies for queues and topics.
    activemq::policy{'queues':
        type       => 'queue',
        path       => '*.reply.',
        attributes => { 'gcInactiveDestinations' => 'true',
                        'inactiveTimoutBeforeGC' => '300000',
                      }
    }
    activemq::policy{'topics':
        type       => 'topic',
        path       => '>',
        attributes => {'producerFlowControl' => 'false'}
    }

    # The following is to create uniplex network connecters between
    # two brokers , broker1 and broker2.
    $otherfqdn = $::fqdn ? {
       'broker1.example.org' => 'broker2.example.org',
       'broker2.example.org' => 'broker1.example.org',
    }
    activemq::network{"${::fqdn}-${otherfqdn}-topics":
        name                            => "${::fqdn}-${otherfqdn}-topics",
        uri                             => "static:(tcp://${otherfqdn}:61616)",
        username                        => 'activemq',
        password                        => 'xyz',
        duplex                          => false,
        decreaseNetworkConsumerPriority => true,
        networkTTL                      => '2',
        dynamicOnly                     => true,
        conduitSubscriptions            => true,
        excludedDestinationsType        => 'topic',
        excludedDestinationsPath        => '>'
    }
    activemq::network{"${::fqdn}-${otherfqdn}-queues":
        name                            => "${::fqdn}-${otherfqdn}-queues",
        uri                             => "static:(tcp://${otherfqdn}:61616)",
        username                        => 'activemq',
        password                        => 'xyz',
        duplex                          => false,
        decreaseNetworkConsumerPriority => true,
        networkTTL                      => '2',
        dynamicOnly                     => true,
        conduitSubscriptions            => false,
        excludedDestinationsType        => 'queue',
        excludedDestinationsPath        => '>'
    }

Todo

  • The current method that properties are set in activemq-wrapper.conf assumes an intial state of the activemq-wrapper.conf file. Should be improved.
  • For the java keystore only a keystore is created but no truststore is created.
  • Look at making this a pull request to the puppetlabs-activemq module. This is tricky currently as that module has a hardcoded mcollective configuration which ideally would not be a default for the module. Would require a major version bump to puppetlabs-activemq module. Also there are some variable name mismatches such as $configfile vs $config. Also java_ks stuff looks to be done in mcollective module so that has to be handled some how.

License

Apache II license

Contact

steve.traylen@cern.ch

Support

Please log tickets and issues at our github page http://github.com/cernops/puppet-activemq