Module: RuoteAMQP

Defined in:
lib/ruote-amqp.rb,
lib/ruote-amqp/listener.rb,
lib/ruote-amqp/participant.rb

Overview

AMQP participant and listener pair for ruote.

Documentation

See #RuoteAMQP::Listener and #RuoteAMQP::Participant for detailed documentation on using each of them.

AMQP Notes

RuoteAMQP uses durable queues and persistent messages by default, to ensure no messages get lost along the way and that running expressions doesn’t have to be restarted in order for messages to be resent.

Defined Under Namespace

Classes: Listener, Participant

Constant Summary collapse

VERSION = 
'0.9.21.1'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.use_persistent_messages=(value) ⇒ Object (writeonly)

Sets the attribute use_persistent_messages

Parameters:

  • value —

    the value to set the attribute use_persistent_messages to.



41
42
43
 
# File 'lib/ruote-amqp.rb', line 41

def use_persistent_messages=(value)
  @use_persistent_messages = value
end

Class Method Details

.use_persistent_messages? ⇒ Boolean

Whether or not to use persistent messages (true by default)

Returns:

  • (Boolean) 


44
45
46
47
 
# File 'lib/ruote-amqp.rb', line 44

def use_persistent_messages?
  @use_persistent_messages = true if @use_persistent_messages.nil?
  @use_persistent_messages
end