Class: TorqueBox::Messaging::MessageProcessor

Inherits:
Object
  • Object
show all
Includes:
ProcessorMiddleware::DefaultMiddleware
Defined in:
lib/torquebox/messaging/message_processor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from ProcessorMiddleware::DefaultMiddleware

default, #middleware

Constructor Details

#initialize ⇒ MessageProcessor

Returns a new instance of MessageProcessor.



27
28
29
 
# File 'lib/torquebox/messaging/message_processor.rb', line 27

def initialize
  @message = nil 
end

Instance Attribute Details

#message ⇒ Object

Returns the value of attribute message.



25
26
27
 
# File 'lib/torquebox/messaging/message_processor.rb', line 25

def message
  @message
end

Instance Method Details

#on_error(error) ⇒ Object 



35
36
37
 
# File 'lib/torquebox/messaging/message_processor.rb', line 35

def on_error(error)
  raise error
end

#on_message(body) ⇒ Object 



31
32
33
 
# File 'lib/torquebox/messaging/message_processor.rb', line 31

def on_message(body)
  throw "Your subclass must implement on_message(body)"
end

#process!(message) ⇒ Object 



39
40
41
42
43
44
45
46
 
# File 'lib/torquebox/messaging/message_processor.rb', line 39

def process!(message)
  @message = message
  begin
    on_message( message.decode )
  rescue Exception => e
    on_error( e ) 
  end 
end