Class: EventQ::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/eventq_base/queue.rb

Direct Known Subclasses

EventRaisedQueue

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Queue

Returns a new instance of Queue.



13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/eventq_base/queue.rb', line 13

def initialize
  @allow_retry = false
  # Default retry back off settings
  @allow_retry_back_off = false
  # Default max receive count is 30
  @max_receive_count = 30
  # Default max retry attempts is 5
  @max_retry_attempts = 5
  # Default require signature to false
  @require_signature = false
  # Default retry delay is 30 seconds
  @retry_delay = 30000
end

Instance Attribute Details

#allow_retry ⇒ Object

Returns the value of attribute allow_retry.



3
4
5
 
# File 'lib/eventq_base/queue.rb', line 3

def allow_retry
  @allow_retry
end

#allow_retry_back_off ⇒ Object

Returns the value of attribute allow_retry_back_off.



4
5
6
 
# File 'lib/eventq_base/queue.rb', line 4

def allow_retry_back_off
  @allow_retry_back_off
end

#dlq ⇒ Object

Returns the value of attribute dlq.



5
6
7
 
# File 'lib/eventq_base/queue.rb', line 5

def dlq
  @dlq
end

#max_receive_count ⇒ Object

Returns the value of attribute max_receive_count.



9
10
11
 
# File 'lib/eventq_base/queue.rb', line 9

def max_receive_count
  @max_receive_count
end

#max_retry_attempts ⇒ Object

Returns the value of attribute max_retry_attempts.



6
7
8
 
# File 'lib/eventq_base/queue.rb', line 6

def max_retry_attempts
  @max_retry_attempts
end

#max_retry_delay ⇒ Object

Returns the value of attribute max_retry_delay.



7
8
9
 
# File 'lib/eventq_base/queue.rb', line 7

def max_retry_delay
  @max_retry_delay
end

#name ⇒ Object

Returns the value of attribute name.



8
9
10
 
# File 'lib/eventq_base/queue.rb', line 8

def name
  @name
end

#require_signature ⇒ Object

Returns the value of attribute require_signature.



10
11
12
 
# File 'lib/eventq_base/queue.rb', line 10

def require_signature
  @require_signature
end

#retry_delay ⇒ Object

Returns the value of attribute retry_delay.



11
12
13
 
# File 'lib/eventq_base/queue.rb', line 11

def retry_delay
  @retry_delay
end