Class Queueue::Message
In: lib/queueue/queue.rb
Parent: Object

Methods

lock!   locked?   new  

Attributes

body  [R] 
message_id  [R] 
visibility_timeout  [RW] 

Public Class methods

new(body, timeout)

A MissingParameter exception will be raised, unless the Message has a body.

[Source]

# File lib/queueue/queue.rb, line 74
    def initialize(body, timeout)
      raise MissingParameter.new("MessageBody") unless body
      @body, @visibility_timeout, @message_id = body, timeout, generate_id
      @lock_timestamp = 0
    end

Public Instance methods

lock!()

Prevent the message from being viewed for the duration of the Message‘s Visibility Timeout.

[Source]

# File lib/queueue/queue.rb, line 82
    def lock!
      @lock_timestamp = Time.now
    end
locked?()

True if the Message‘s Visibility Timeout has not expired.

[Source]

# File lib/queueue/queue.rb, line 87
    def locked?
      (Time.now - @lock_timestamp).to_i < @visibility_timeout
    end

[Validate]