def create
      processors = Processor.subscribers_for(params[:queue])
      
      if processors.empty?
        render :status => 404, :nothing => true
        return
      end
      
      processors.each do |processor|
        processor.process(params[:message])
      end
      
      render :status => 200, :nothing => true
    end
def create
      processors = Processor.subscribers_for(params[:queue])
      
      if processors.empty?
        render :status => 404, :nothing => true
        return
      end
      
      processors.each do |processor|
        processor.process(params[:message])
      end
      
      render :status => 200, :nothing => true
    end
POST /operator/:queue

 Find all the matching `Processor`s and let them process the message in
 `params[:message]`.

 If no `Processor` can be found, a 404 will be raised.

 If any of the `Processor`s raise an exception, a 500 error will be
 raised and the processing wilt stop immediately