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