lib/pigeon/queue.rb
def filter(filter_name, &block)
    raise BlockRequired unless (block_given?)

    @filters.synchronize do
      @filters[filter_name] = block
    end
    
    assign_next_task(filter_name)
  end
# Creates a named filter for the queue using the provided block to select
# the tasks which should match.
Creates a named filter for the queue using the provided block to select
the tasks which should match.
Creates a named filter for the queue using the provided block to select the tasks which should match .
def filter(filter_name, &block)
    raise BlockRequired unless (block_given?)
    @filters.synchronize do
      @filters[filter_name] = block
    end
    assign_next_task(filter_name)
  end
def filter ( filter_name , & block ) raise BlockRequired unless ( block_given? ) @filters . synchronize do @filters [ filter_name ] = block end assign_next_task ( filter_name ) end
Creates a named filter for the queue using the provided block to select
the tasks which should match.
Creates a named filter for the queue using the provided block to select the tasks which should match .
filter_name
block