Module: Amqpop

Defined in:
lib/amqpop/cli.rb,
lib/amqpop/amqpop.rb,
lib/amqpop/message.rb,
lib/amqpop/version.rb,
lib/amqpop/auth_file.rb,
lib/amqpop/lock_file.rb

Defined Under Namespace

Classes: AuthFile, CLI, LockFile, Message

Constant Summary collapse

VERSION = 
"0.0.2"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.connection ⇒ Object

Returns the value of attribute connection.



5
6
7
 
# File 'lib/amqpop/amqpop.rb', line 5

def connection
  @connection
end

.options ⇒ Object

Returns the value of attribute options.



4
5
6
 
# File 'lib/amqpop/amqpop.rb', line 4

def options
  @options
end

Class Method Details

.eputs(msg) ⇒ Object 



20
21
22
 
# File 'lib/amqpop/amqpop.rb', line 20

def self.eputs(msg)
  STDERR.puts msg
end

.require_ack? ⇒ Boolean

Returns:

  • (Boolean) 


10
11
12
13
 
# File 'lib/amqpop/amqpop.rb', line 10

def self.require_ack?
   return nil if options.nil?
  !temp_queue?
end

.temp_queue? ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
18
 
# File 'lib/amqpop/amqpop.rb', line 15

def self.temp_queue?
	return nil if options.nil?
  options[:queue_name] == ""
end

.verbose? ⇒ Boolean

Returns:

  • (Boolean) 


28
29
30
31
 
# File 'lib/amqpop/amqpop.rb', line 28

def self.verbose?
  return nil if options.nil?
  options[:verbose]
end

.vputs(msg) ⇒ Object 



24
25
26
 
# File 'lib/amqpop/amqpop.rb', line 24

def self.vputs(msg)
  eputs "> #{msg}" if verbose?
end