Class: Krakow::FrameType::Message

Inherits:

Krakow::FrameType

• Object
• Krakow::FrameType
• Krakow::FrameType::Message

show all

Defined in:

lib/krakow/frame_type/message.rb

Overview

Constant Summary

Instance Attribute Summary (collapse)

• - (Hash) arguments included from Utils::Lazy::InstanceMethods readonly

  Argument hash.

• - (Krakow::Consumer) origin

Attributes (collapse)

• - (Integer) attempts

  The attempts attribute.

• - (TrueClass, FalseClass) attempts?

  Truthiness of the attempts attribute.

• - (String) message

  The message attribute.

• - (TrueClass, FalseClass) message?

  Truthiness of the message attribute.

• - (String) message_id

  The message_id attribute.

• - (TrueClass, FalseClass) message_id?

  Truthiness of the message_id attribute.

• - (Integer) timestamp

  The timestamp attribute.

• - (TrueClass, FalseClass) timestamp?

  Truthiness of the timestamp attribute.

Instance Method Summary (collapse)

• - (Object) confirm(*args) (also: #finish)

  Proxy to [Krakow::Consumer#confirm].

• - (String) content

  Message content.

• - (Object) requeue(*args)

  Proxy to [Krakow::Consumer#requeue].

• - (Object) touch(*args)

  Proxy to [Krakow::Consumer#touch].

9
10
11

# File 'lib/krakow/frame_type/message.rb', line 9

def origin
  @origin
end

18

# File 'lib/krakow/frame_type/message.rb', line 18

attribute :attempts, Integer, :required => true

18

# File 'lib/krakow/frame_type/message.rb', line 18

attribute :attempts, Integer, :required => true

42
43
44

# File 'lib/krakow/frame_type/message.rb', line 42

def confirm(*args)
  origin.confirm(*[self, *args].compact)
end

28
29
30

# File 'lib/krakow/frame_type/message.rb', line 28

def content
  message
end

21

# File 'lib/krakow/frame_type/message.rb', line 21

attribute :message, String, :required => true

21

# File 'lib/krakow/frame_type/message.rb', line 21

attribute :message, String, :required => true

20

# File 'lib/krakow/frame_type/message.rb', line 20

attribute :message_id, String, :required => true

20

# File 'lib/krakow/frame_type/message.rb', line 20

attribute :message_id, String, :required => true

48
49
50

# File 'lib/krakow/frame_type/message.rb', line 48

def requeue(*args)
  origin.requeue(*[self, *args].compact)
end

19

# File 'lib/krakow/frame_type/message.rb', line 19

attribute :timestamp, Integer, :required => true

19

# File 'lib/krakow/frame_type/message.rb', line 19

attribute :timestamp, Integer, :required => true

53
54
55

# File 'lib/krakow/frame_type/message.rb', line 53

def touch(*args)
  origin.touch(*[self, *args].compact)
end