Sha256: b8b59fabecbbb6ce409b332d82193d66bcf4138021b3c339435eda29065afd0a

Contents?: true

Size: 390 Bytes

Versions: 3

Compression:

Stored size: 390 Bytes

Contents

class KJess::Request
  class Get < KJess::Request
    keyword 'GET'
    arity   1
    valid_responses [ KJess::Response::Value ]

    def parse_options_to_args( opts )
      a = [ opts[:queue_name] ]

      a << "t=#{opts[:wait_for]}" if opts[:wait_for]

      [ :open, :close, :abort, :peek ].each do |o|
        a << o.to_s if opts[o]
      end

      [ a.join("/") ]
    end
  end
end


Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
kjess-1.2.0 lib/kjess/request/get.rb
kjess-1.1.0 lib/kjess/request/get.rb
kjess-1.0.0 lib/kjess/request/get.rb