Module: Qsagi::Queue::ClassMethods

Defined in:
lib/qsagi/queue.rb

Instance Method Summary collapse

Instance Method Details

#_exchange ⇒ Object 



78
79
80
 
# File 'lib/qsagi/queue.rb', line 78

def _exchange
  @exchange || ""
end

#_message_class ⇒ Object 



82
83
84
 
# File 'lib/qsagi/queue.rb', line 82

def _message_class
  @message_class || Qsagi::Message
end

#_serializer ⇒ Object 



86
87
88
 
# File 'lib/qsagi/queue.rb', line 86

def _serializer
  @serializer || Qsagi::DefaultSerializer
end

#connect(&block) ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/qsagi/queue.rb', line 54

def connect(&block)
  queue = new

  begin
    queue.connect

    block.call(queue)
  ensure
    queue.disconnect
  end
end

#exchange(exchange) ⇒ Object 



66
67
68
 
# File 'lib/qsagi/queue.rb', line 66

def exchange(exchange)
  @exchange = exchange
end

#message_class(message_class) ⇒ Object 



70
71
72
 
# File 'lib/qsagi/queue.rb', line 70

def message_class(message_class)
  @message_class = message_class
end

#serializer(serializer) ⇒ Object 



74
75
76
 
# File 'lib/qsagi/queue.rb', line 74

def serializer(serializer)
  @serializer = serializer
end