Class: TDL::QueueBasedImplementationRunner::ApplyProcessingRules

Inherits:
Object
  • Object
show all
Defined in:
lib/tdl/queue/queue_based_implementation_runner.rb

Instance Method Summary collapse

Constructor Details

#initialize(processing_rules) ⇒ ApplyProcessingRules

Returns a new instance of ApplyProcessingRules.



49
50
51
52
53
 
# File 'lib/tdl/queue/queue_based_implementation_runner.rb', line 49

def initialize(processing_rules)
  @processing_rules = processing_rules
  @logger = Logging.logger[self]
  @audit = AuditStream.new
end

Instance Method Details

#process_next_request_from(remote_broker, request) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/tdl/queue/queue_based_implementation_runner.rb', line 55

def process_next_request_from(remote_broker, request)
  @audit.start_line
  @audit.log(request)
      
  # Obtain response from user
  response = @processing_rules.get_response_for(request)
  @audit.log(response)
      
  # Obtain action
  client_action = response.client_action
      
  # Act
  client_action.after_response(remote_broker, request, response)
  @audit.log(client_action)
  @audit.end_line
  client_action.prepare_for_next_request(remote_broker)
end