Class: Sparrow::Queues::Memory

Inherits:
Object
  • Object
show all
Includes:
Miscel
Defined in:
lib/sparrow/queues/memory.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Miscel

#base_dir, #log_path, #logger, #options, #options=, #pid_dir

Constructor Details

#initialize(queue_name) ⇒ Memory

Returns a new instance of Memory.



11
12
13
14
15
16
17
 
# File 'lib/sparrow/queues/memory.rb', line 11

def initialize(queue_name)
  self.queue_name = queue_name
  self.queue_data = []
  self.count_pop = 0
  self.count_push = 0
  recover!
end

Instance Attribute Details

#count_pop ⇒ Object

Returns the value of attribute count_pop.



8
9
10
 
# File 'lib/sparrow/queues/memory.rb', line 8

def count_pop
  @count_pop
end

#count_push ⇒ Object

Returns the value of attribute count_push.



9
10
11
 
# File 'lib/sparrow/queues/memory.rb', line 9

def count_push
  @count_push
end

#queue_data ⇒ Object

Returns the value of attribute queue_data.



7
8
9
 
# File 'lib/sparrow/queues/memory.rb', line 7

def queue_data
  @queue_data
end

#queue_name ⇒ Object

Returns the value of attribute queue_name.



6
7
8
 
# File 'lib/sparrow/queues/memory.rb', line 6

def queue_name
  @queue_name
end

Instance Method Details

#clear! ⇒ Object 



29
30
31
32
 
# File 'lib/sparrow/queues/memory.rb', line 29

def clear!
  self.queue_data = []
  self.sqlite.clear!
end

#count ⇒ Object 



34
35
36
 
# File 'lib/sparrow/queues/memory.rb', line 34

def count
  queue_data.length
end

#pop ⇒ Object 



19
20
21
22
 
# File 'lib/sparrow/queues/memory.rb', line 19

def pop
  self.count_pop += 1
  self.queue_data.shift
end

#push(value) ⇒ Object 



24
25
26
27
 
# File 'lib/sparrow/queues/memory.rb', line 24

def push(value)
  self.count_push += 1
  self.queue_data.push(value)
end

#recover! ⇒ Object 



50
51
52
53
54
55
 
# File 'lib/sparrow/queues/memory.rb', line 50

def recover!
  logger.debug "Recovering queue"
  while msg = self.sqlite.pop
    self.push(msg)
  end
end

#shutdown! ⇒ Object 



46
47
48
 
# File 'lib/sparrow/queues/memory.rb', line 46

def shutdown!
  self.to_disk!
end

#sqlite ⇒ Object 



57
58
59
 
# File 'lib/sparrow/queues/memory.rb', line 57

def sqlite
  @sqlite ||= Sparrow::Queues::Sqlite.new(self.queue_name)
end

#to_disk! ⇒ Object 



38
39
40
41
42
43
44
 
# File 'lib/sparrow/queues/memory.rb', line 38

def to_disk!
  copy = self.queue_data.dup
  copy.each do |value|
    self.sqlite.push(value)
  end
  self.queue_data = self.queue_data - copy
end