vendor/bundle/ruby/1.8/gems/activemessaging-0.9.0/lib/activemessaging/processor.rb
def process!(message)
      @message = message
      return on_message(message.body)
    rescue Object=>err
      begin
        on_error(err)
      rescue ActiveMessaging::AbortMessageException => rpe
        logger.error "Processor:process! - AbortMessageException caught."
        raise rpe
      rescue Object=>ex
        logger.error "Processor:process! - error in on_error, will propagate no further: #{ex.message}\n\t#{ex.backtrace.join("\n\t")}"
      end
    end
# Bind the processor to the current message so that the processor could
# potentially access headers and other attributes of the message
Bind the processor to the current message so that the processor could
potentially access headers and other attributes of the message
Bind the processor to the current message so that the processor could potentially access headers and other attributes of the message
def process!(message)
      @message = message
      return on_message(message.body)
    rescue Object=>err
      begin
        on_error(err)
      rescue ActiveMessaging::AbortMessageException => rpe
        logger.error "Processor:process! - AbortMessageException caught."
        raise rpe
      rescue Object=>ex
        logger.error "Processor:process! - error in on_error, will propagate no further: #{ex.message}\n\t#{ex.backtrace.join("\n\t")}"
      end
    end
def process! ( message ) @message = message return on_message ( message . body ) rescue Object => err begin on_error ( err ) rescue ActiveMessaging :: AbortMessageException => rpe logger . error "Processor:process! - AbortMessageException caught." raise rpe rescue Object => ex logger . error "Processor:process! - error in on_error, will propagate no further: #{ex.message}\n\t#{ex.backtrace.join("\n\t")}" end end
Bind the processor to the current message so that the processor could
potentially access headers and other attributes of the message
Bind the processor to the current message so that the processor could potentially access headers and other attributes of the message
message