lib/agent/queue.rb in agent-0.9.1 vs lib/agent/queue.rb in agent-0.10.0

@@ -80,10 +80,10 @@
 
     def pop(options={})
       pop = Pop.new(options)
 
       mutex.synchronize do
-        raise Errors::ChannelClosed if @closed
+        pop.close if @closed
         operations << pop
         pops << pop
         process
       end