lib/queuel.rb in queuel-0.1.0 vs lib/queuel.rb in queuel-0.2.0

- old
+ new

@@ -1,7 +1,9 @@ require "queuel/version" require "forwardable" +require "queuel/core_ext/hash" +require "queuel/serialization/json" require "queuel/configurator" require "queuel/introspect" require "queuel/base/engine" require "queuel/base/queue" @@ -22,11 +24,18 @@ module Queuel extend Introspect class << self extend Forwardable - def_delegators :client, :push, :pop, :receive, :with - def_delegators :config, :credentials, :default_queue, :receiver_threads + def_delegators :client, :peek, :push, :pop, :receive, :with + def_delegators :config, + :credentials, + :default_queue, + :receiver_threads, + :decode_by_default?, + :decoder, + :encode_by_default?, + :encoder alias << pop end def self.engine requires