Class: Cosmo::Stream::Message

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/cosmo/stream/message.rb,
sig/cosmo/stream/message.rbs

Instance Method Summary collapse

Constructor Details

#initialize(msg, serializer: nil) ⇒ Message

Returns a new instance of Message.

Parameters:

  • msg (Object)
  • serializer: (Module, nil) (defaults to: nil) 


13
14
15
16
 
# File 'lib/cosmo/stream/message.rb', line 13

def initialize(msg, serializer: nil)
  @msg = msg
  @serializer = serializer || Serializer
end

Instance Method Details

#ack ⇒ void

This method returns an undefined value.



15
 
# File 'sig/cosmo/stream/message.rbs', line 15

def ack: () -> void

#consumer_sequence ⇒ Integer

Returns:

  • (Integer) 


26
27
28
 
# File 'lib/cosmo/stream/message.rb', line 26

def consumer_sequence
  metadata.sequence.consumer
end

#data ⇒ Object

Returns:

  • (Object) 


18
19
20
 
# File 'lib/cosmo/stream/message.rb', line 18

def data
  @serializer.deserialize(@msg.data)
end

#header ⇒ Hash[::String, untyped]

Returns:

  • (Hash[::String, untyped]) 


13
 
# File 'sig/cosmo/stream/message.rbs', line 13

def header: () -> Hash[::String, untyped]

#in_progress ⇒ void

This method returns an undefined value.



35
 
# File 'sig/cosmo/stream/message.rbs', line 35

def in_progress: () -> void

#metadata ⇒ Object

Returns:

  • (Object) 


23
 
# File 'sig/cosmo/stream/message.rbs', line 23

def metadata: () -> untyped

#nack ⇒ void

This method returns an undefined value.

Parameters:

  • delay: (Integer, nil) 


17
 
# File 'sig/cosmo/stream/message.rbs', line 17

def nack: (?delay: Integer?) -> void

#num_delivered ⇒ Integer

Returns:

  • (Integer) 


31
 
# File 'sig/cosmo/stream/message.rbs', line 31

def num_delivered: () -> Integer

#num_pending ⇒ Integer

Returns:

  • (Integer) 


33
 
# File 'sig/cosmo/stream/message.rbs', line 33

def num_pending: () -> Integer

#reply ⇒ ::String?

Returns:

  • (::String, nil) 


11
 
# File 'sig/cosmo/stream/message.rbs', line 11

def reply: () -> ::String?

#stream_sequence ⇒ Integer

Returns:

  • (Integer) 


22
23
24
 
# File 'lib/cosmo/stream/message.rb', line 22

def stream_sequence
  metadata.sequence.stream
end

#subject ⇒ ::String

Returns:

  • (::String) 


9
 
# File 'sig/cosmo/stream/message.rbs', line 9

def subject: () -> ::String

#term ⇒ void

This method returns an undefined value.



19
 
# File 'sig/cosmo/stream/message.rbs', line 19

def term: () -> void

#timestamp ⇒ Time

Returns:

  • (Time) 


29
 
# File 'sig/cosmo/stream/message.rbs', line 29

def timestamp: () -> Time