Class: Fleck::Consumer::Request

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/fleck/consumer/request.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Loggable

#logger

Constructor Details

#initialize(metadata, payload) ⇒ Request

Returns a new instance of Request.



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/fleck/consumer/request.rb', line 8

def initialize(metadata, payload)
  @id              = metadata.correlation_id
  logger.progname += " #{@id}"

  @metadata = metadata
  @payload  = payload
  @data     = {}
  @headers  = {}
  @action   = nil
  @params   = {}
  @status   = 200
  @errors   = []

  parse_request!
end

Instance Attribute Details

#action ⇒ Object (readonly)

Returns the value of attribute action.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def action
  @action
end

#data ⇒ Object (readonly)

Returns the value of attribute data.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def data
  @data
end

#errors ⇒ Object (readonly)

Returns the value of attribute errors.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def errors
  @errors
end

#headers ⇒ Object (readonly)

Returns the value of attribute headers.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def headers
  @headers
end

#id ⇒ Object (readonly)

Returns the value of attribute id.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def id
  @id
end

#metadata ⇒ Object (readonly)

Returns the value of attribute metadata.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def metadata
  @metadata
end

#params ⇒ Object (readonly)

Returns the value of attribute params.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def params
  @params
end

#payload ⇒ Object (readonly)

Returns the value of attribute payload.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def payload
  @payload
end

#status ⇒ Object (readonly)

Returns the value of attribute status.



6
7
8
 
# File 'lib/fleck/consumer/request.rb', line 6

def status
  @status
end