Make it all work

This is the refactored version of emque with focus on making this consumer centric.  It eliminates the retry/failure topics, while adding context to errors so that services can decide how to retry things after making any necessary fixes.  It also works to adopt the functional/pipe approaches from APIv3.
argghhh, nope other than git keeps replacing that during rebases


On Sep 22, 2014, at 1:10 PM, Geoff Lanotte <notifications@github.com> wrote:

> In lib/emque/consuming/consumer.rb:
> 
> >  
> > -        def each_before_filter(action, &block)
> > -          self.before_filters = [] if !before_filters
> > -          each_filter(before_filters, action, &block)
> > -        end
> > +    class Consumer
> > +      #include ::Emque::Consuming.consumer
> is there a reason you left this commented out?
> 
> —
> Reply to this email directly or view it on GitHub.
>