Module: Puppet_X::Coi::Jboss::Provider::Jmsqueue

Includes:
BuildinsUtils
Defined in:
lib/puppet_x/coi/jboss/provider/jmsqueue.rb

Overview

A module for Jmsqueue

Instance Method Summary collapse

Instance Method Details

#createObject

Method that creates jms-queue in JBoss instance.



6
7
8
9
10
11
12
13
14
15
16
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 6

def create
  profile = calc_profile
  entries = @resource[:entries].join '", "'
  raise 'Array of entries can not be empty' if entries.empty?
  entries = format('["%s"]', entries)
  durable = ToBooleanConverter.new(@resource[:durable]).to_bool
  ensure_default_hornetq
  cmd = "jms-queue #{profile} add --queue-address=#{@resource[:name]} " \
    "--entries=#{entries} --durable=#{durable}"
  bringUp 'JMS Queue', cmd
end

#destroyObject

Method to remove jms-queue from Jboss instance.



19
20
21
22
23
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 19

def destroy
  profile = calc_profile
  cmd = "jms-queue #{profile} remove --queue-address=#{@resource[:name]}"
  bringDown 'JMS Queue', cmd
end

#durableObject

Standard getter for durable value.



36
37
38
39
40
41
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 36

def durable
  trace 'durable'
  Puppet.debug "Durable given: #{@resource[:durable].inspect}"
  # normalization
  ToBooleanConverter.new(@data['durable']).to_bool.to_s
end

#durable=(value) ⇒ Object

Standard setter for durable value.

Parameters:

  • value (Boolean)

    a value of durable, can be true or false



46
47
48
49
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 46

def durable=(value)
  trace format('durable= %s', value.to_s)
  setattr 'durable', format('"%s"', ToBooleanConverter.new(value).to_bool)
end

#entriesObject

Standard getter for entries value.



52
53
54
55
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 52

def entries
  trace 'entries'
  @data['entries']
end

#entries=(value) ⇒ Object

Standard setter for entries value.

Parameters:

  • value (Array)

    a value of entries



60
61
62
63
64
65
66
67
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 60

def entries=(value)
  trace format('entries= %s', value.inspect)
  entries = value.join '", "'
  raise 'Array of entries can not be empty' if entries.empty?

  entries = format('["%s"]', entries)
  setattr 'entries', entries
end

#exists?Boolean

Method to check if there is jms-queue. Methods calls read-resource to validate if jms-queue is present.

Returns:

  • (Boolean)


26
27
28
29
30
31
32
33
# File 'lib/puppet_x/coi/jboss/provider/jmsqueue.rb', line 26

def exists?
  result = loaddata
  unless result[:result]
    Puppet.debug 'JMS Queue do not exists'
    return false
  end
  true
end