Class: Daemon::Messaging::Message

Inherits:

Object

• Object
• Daemon::Messaging::Message

show all

Includes:

Comparable

Defined in:

lib/onapp/engine/messaging/message.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) metadata readonly

  Returns the value of attribute metadata.

• - (Object) payload readonly

  Returns the value of attribute payload.

Instance Method Summary (collapse)

• - (Object) <=>(other)

  Used in PQueue for comparing messages.

• - (Object) ack
• - (Message) initialize(metadata, payload) constructor

  A new instance of Message.

• - (Object) reject
• - (Object) requeue
• - (Object) seconds_since_publish deprecated Deprecated.

9
10
11

# File 'lib/onapp/engine/messaging/message.rb', line 9

def initialize(metadata, payload)
  @metadata, @payload = metadata, payload
end

7
8
9

# File 'lib/onapp/engine/messaging/message.rb', line 7

def metadata
  @metadata
end

7
8
9

# File 'lib/onapp/engine/messaging/message.rb', line 7

def payload
  @payload
end

32
33
34

# File 'lib/onapp/engine/messaging/message.rb', line 32

def <=>(other)
  metadata.priority <=> other.metadata.priority
end

26
27
28
29

# File 'lib/onapp/engine/messaging/message.rb', line 26

def ack
  @done || metadata.ack
  @done = true
end

14
15
16
17

# File 'lib/onapp/engine/messaging/message.rb', line 14

def reject
  @done || metadata.reject
  @done = true
end

20
21
22
23

# File 'lib/onapp/engine/messaging/message.rb', line 20

def requeue
  @done || metadata.reject(requeue: true)
  @done = true
end

38
39
40
41
42

# File 'lib/onapp/engine/messaging/message.rb', line 38

def seconds_since_publish
  if metadata.timestamp
    Time.now.utc - metadata.timestamp.utc
  end
end