Method: Sparrow::Server#process_body

Defined in:
lib/sparrow/server.rb

#process_body ⇒ Object 



158
159
160
161
162
163
164
165
166
167
168
169
170
 
# File 'lib/sparrow/server.rb', line 158

def process_body
  if @data.length != @expected_bytes
   raise InvalidBodyLength
  end
  @data << @current_flag
  logger.debug "Adding message to queue - #{@current_queue}"
  Sparrow::Queue.add_message(@current_queue, @data)
  self.set_count += 1
  @expected_bytes = 0
  @current_queue = nil
  @expecting_body = false
  publish STORED
end