Class: RServiceBus::Stats

Inherits:
Object
  • Object
show all
Defined in:
lib/rservicebus/Stats.rb

Overview

Used to collect various run time stats for runtime reporting

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Stats

Returns a new instance of Stats.



6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/rservicebus/Stats.rb', line 6

def initialize
  @hash = Hash.new

  @totalProcessed = 0
  @totalErrored = 0
  @totalSent = 0
  @totalPublished = 0
  @totalReply = 0

  @totalByMessageType = Hash.new
       
       @written = false

end

Instance Method Details

#getForReporting ⇒ Object 



69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/rservicebus/Stats.rb', line 69

def getForReporting
  string = "T:#{@totalProcessed};E:#{@totalErrored};S:#{@totalSent};P:#{@totalPublished};R:#{@totalReply}"

#   if @hash.length > 0 then
#     @hash.each do |k,v|
#       string = "#{string};#{k}:#{v}"
#     end
#   end
  
  return string
end

#getForReporting2 ⇒ Object 



57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/rservicebus/Stats.rb', line 57

def getForReporting2
    if @written == false then
        @written = true
        types = Hash.new(0)
        ObjectSpace.each_object do|obj|
            types[obj.class]+=1
        end

        return types
    end
end

#inc(key) ⇒ Object 



41
42
43
44
45
46
 
# File 'lib/rservicebus/Stats.rb', line 41

def inc( key )
  if @hash[key].nil? then
    @hash[key] = 0
  end
  @hash[key] = @hash[key] + 1
end

#incMessageType(className) ⇒ Object 



48
49
50
51
52
53
54
55
 
# File 'lib/rservicebus/Stats.rb', line 48

def incMessageType( className )
  if @totalByMessageType[className].nil? then
    @totalByMessageType[className] = 1
  else
    @totalByMessageType[className] = @totalByMessageType[className] + 1
  end

end

#incTotalErrored ⇒ Object 



25
26
27
 
# File 'lib/rservicebus/Stats.rb', line 25

def incTotalErrored
  @totalErrored = @totalErrored + 1
end

#incTotalProcessed ⇒ Object 



21
22
23
 
# File 'lib/rservicebus/Stats.rb', line 21

def incTotalProcessed
  @totalProcessed = @totalProcessed + 1
end

#incTotalPublished ⇒ Object 



33
34
35
 
# File 'lib/rservicebus/Stats.rb', line 33

def incTotalPublished
  @totalPublished = @totalPublished + 1
end

#incTotalReply ⇒ Object 



37
38
39
 
# File 'lib/rservicebus/Stats.rb', line 37

def incTotalReply
  @totalReply = @totalReply + 1
end

#incTotalSent ⇒ Object 



29
30
31
 
# File 'lib/rservicebus/Stats.rb', line 29

def incTotalSent
  @totalSent = @totalSent + 1
end