Method: ContentServer::FileCopyServer#receive_message

Defined in:
lib/content_server/queue_copy.rb

#receive_message(addr_info, message) ⇒ Object 



158
159
160
161
162
163
 
# File 'lib/content_server/queue_copy.rb', line 158

def receive_message(addr_info, message)
  # Add ack message to copy queue.
  Log.debug2("Content server Copy message received: %s", message)
  @copy_input_queue.push(message)
  $process_vars.set('Copy File Queue Size', @copy_input_queue.size)
end